Details
-
Improvement
-
Status: Open
-
Major
-
Resolution: Unresolved
-
None
-
None
Description
We introduced custom error handling for the Kinesis EFO Consumer as part of https://issues.apache.org/jira/browse/FLINK-33260
PR for the EFO consumer: https://github.com/apache/flink-connector-aws/pull/110
This ticket is to apply the same logic to the Kinesis Polling Consumer in the same codebase.
Current configuration for the EFO consumer looks like:
flink.shard.consumer.error.recoverable[0].exception=java.net.UnknownHostException flink.shard.consumer.error.recoverable[1].exception=java.net.SocketTimeoutException
We should re-use the same code for the polling consumer.
Attachments
Issue Links
- relates to
-
FLINK-33260 Custom Error Handling for Kinesis EFO Consumer
- Resolved