[jira] [Created] (FLINK-33991) Custom Error Handling for Kinesis Polling Consumer

["Emre Kartoglu (Jira)" <ji...@apache.org>]

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)