amazon-kinesis-client
amazon-kinesis-client copied to clipboard
KCL v2 consumer does not backoff on ProvisionedThroughputExceededException
In KCL v1 com.amazonaws.services.kinesis.clientlibrary.lib.worker.ProcessTask
used to fetch records and yield a short message on ProvisionedThroughputExceededException
using ThrottlingReporter
and then backoff. In KCL v2 records are fetched upstream by PrefetchRecordsPublisher
and then passed to software.amazon.kinesis.lifecycle.ProcessTask
. PrefetchRecordsPublisher
handles ProvisionedThroughputExceededException
as a common SDK error, specifically it logs a stack trace and does not force a backoff. Is it an intended change or a regression?
Any updates on this issue? I see pull request https://github.com/awslabs/amazon-kinesis-client/pull/716, but this has not been merged.
any updates?