Emre Kartoglu created FLINK-33991:
-------------------------------------
Summary: Custom Error Handling for Kinesis Polling Consumer
Key: FLINK-33991
URL: https://issues.apache.org/jira/browse/FLINK-33991
Project: Flink
Issue Type: Improvement
Components: Connectors / Kinesis
Affects Versions: aws-connector-4.2.0
Reporter: Emre Kartoglu
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:
{{}}
{code:java}
flink.shard.consumer.error.recoverable[0].exception=java.net.UnknownHostException
flink.shard.consumer.error.recoverable[1].exception=java.net.SocketTimeoutException
{code}
{{}}
We should re-use the same code for the polling consumer.{{{}{}}}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
