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

Kinesis Consumer listShards should support more recoverable exceptions

    Details

      Description

      Currently transient errors in listShards make the consumer fail and cause the entire job to reset. That is unnecessary for certain exceptions (like status 503 errors). It should be possible to control the exceptions that qualify for retry, similar to getRecords/isRecoverableSdkClientException.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                thw Thomas Weise
                Reporter:
                thw Thomas Weise
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: