Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-33991

Custom Error Handling for Kinesis Polling Consumer

    XMLWordPrintableJSON

Details

    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

          Activity

            People

              iemre Emre Kartoglu
              iemre Emre Kartoglu
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated: