Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-6122

Global Consumer should handle TimeoutException

    Details

      Description

      Global consumer does not handle TimeoutException that might be throw by partitonsFor() and endOffsets(). This affect the bootstrapping phase only.

      We need to allow for a proper retry strategy, with configurable max number of retries and back off time between retries. We might need to introduce new configuration parameters – for this case, we need to do a KIP.

      https://cwiki.apache.org/confluence/display/KAFKA/KIP-224%3A+Add+configuration+parameters+%60retries%60+and+%60retry.backoff.ms%60+to+Streams+API

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                mjsax Matthias J. Sax
                Reporter:
                mjsax Matthias J. Sax
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: