Vitalii Kovalenko

KCL v2 consumer does not backoff on ProvisionedThroughputExceededException

2

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...

### Is there an existing issue for this? - [X] I have searched the existing issues ### Kong version (`$ kong version`) 3.3.0 ### Current Behavior Thread for context https://discuss.konghq.com/t/frequent-building-a-new-plugins-iterator/11656....

Race condition in KCL v2 graceful shutdown

4

When graceful shutdown is requested via `Scheduler.startGracefulShutdown` call, it often happens that all active leases get removed from `Scheduler.shardInfoShardConsumerMap` before shutdown of record processors is complete and `GracefulShutdownContext.shutdownCompleteLatch` gets down...