[FLINK-34071][Connectors/Kinesis] Decouple NettyEventLoop thread's onNext() by handing over blocking queue put to a separate executor. Using a shared executor across shards to execute processing of event received by NettyEventLoop.#208

Open

aws-nageshvh wants to merge 4 commits intoapache:mainfrom

aws-nageshvh:efo-backpressure-deadlock-fix

Commits on May 16, 2025

[FLINK-34071][Connectors/Kinesis] Decouple NettyEventLoop thread's onNext() by handing over blocking queue put to a separate executor. Using a shared executor across shards to execute processing of…
aws-nageshvh
committed

Commits on May 20, 2025

[FLINK-34071][Connectors/Kinesis] Handing off kinesis client close to a separate executor so it doesn't block the NettyEventLoop threads, adding null checks, improving logging and documentation.
aws-nageshvh
committed

Commits on May 22, 2025

[FLINK-34071][Connectors/Kinesis] Refactoring splitReader close code and implementing the right ordering, improving error handling, logging and documentation
aws-nageshvh
committed

Commits on May 29, 2025

[FLINK-34071][Connectors/Kinesis] Handing off shard subscription to a separate shared executor and update to tests
aws-nageshvh
committed