Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-5156 Options for handling exceptions in streams
  3. KAFKA-5499

Double check how we handle exceptions when commits fail

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Resolved
    • Major
    • Resolution: Duplicate
    • None
    • None
    • streams
    • None

    Description

      When a task does a lot of processing in-between calls to poll() it happens that it might miss a rebalance. It can find that out once it tries to commit() since it will get an exception. Double check what is supposed to happen on such an exception, e.g., should the thread fail, or should it continue?

      Attachments

        Issue Links

          Is contained by

          Sub-task - The sub-task of the issue KAFKA-4593 Task migration during rebalance callback process could lead the obsoleted task's IllegalStateException

          • Major - Major loss of function.
          • Resolved
          links to

          Web Link GitHub Pull Request #3545

          Activity

            People

              mjsax Matthias J. Sax
              enothereska Eno Thereska
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: