[
https://issues.apache.org/jira/browse/FLINK-33991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Emre Kartoglu updated FLINK-33991:
----------------------------------
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:
{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.
was:
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.{{{{}}{}}}
> 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
> Priority: Major
>
> 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)
