Danny Cranmer created FLINK-33260:
-------------------------------------
Summary: Custom Error Handling for Kinesis Consumer
Key: FLINK-33260
URL: https://issues.apache.org/jira/browse/FLINK-33260
Project: Flink
Issue Type: Improvement
Components: Connectors / Kinesis
Reporter: Danny Cranmer
Background
The Kinesis Consumer exposes various configuration that allows the user to
define retry and backoff strategies when dealing with errors. However, the
configuration does not allow the user to configure which errors are retryable,
or different strategies for different errors. The error handling logic is hard
coded within the connector. Over time we discover errors that should be
retryable that are not, for example KDS throwing 500 on SubscribeToShare or
transient DNS issues.
h3. Scope
Add the ability for the user to define retry/backoff strategy per error. This
could be achieved using flexible configuration keys, or allowing the user to
register their own retry strategies on the connector
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
