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

Options for handling exceptions in streams

    XMLWordPrintableJSON

Details

    • Task
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • 0.10.2.0
    • 1.1.0
    • streams

    Description

      This is a task around options for handling exceptions in streams. It focuses around options for dealing with corrupt data (keep going, stop streams, log, retry, etc).

      Attachments

        Issue Links

          relates to

          Improvement - An improvement or enhancement to an existing feature or task. KAFKA-5942 Handle authentication failures in streams

          • Major - Major loss of function.
          • Open
          1.
          		 Options for handling corrupt data during deserialization Sub-task Resolved Eno Thereska
          2.
          		 KeyValueStore.put may throw exception unrelated to the current put attempt Sub-task Resolved Guozhang Wang
          3.
          		 Improve Streams internal exception handling Sub-task Resolved Matthias J. Sax
          4.
          		 State transitions error PARTITIONS_REVOKED to NOT_RUNNING Sub-task Resolved Eno Thereska
          5.
          		 Improve exception handling on producer path Sub-task Resolved Eno Thereska
          6.
          		 Improve exception handling on consumer path Sub-task Resolved Matthias J. Sax
          7.
          		 Improve exception handling on streams client (communication with brokers) Sub-task Resolved Matthias J. Sax
          8.
          		 Improve exception handling on coordinator interactions Sub-task Resolved Matthias J. Sax
          9.
          		 Improve exception handling for StreamsKafkaClient Sub-task Resolved Eno Thereska
          10.
          		 Improve exception handling for state stores Sub-task Resolved Eno Thereska
          11.
          		 Unexpected state transition Dead to PendingShutdown Sub-task Resolved Eno Thereska
          12.
          		 Double check how we handle exceptions when commits fail Sub-task Resolved Matthias J. Sax
          13.
          		 Check exception handling in all streams tests Sub-task Resolved Evgeny Veretennikov
          14.
          		 Document any changes from this task Sub-task Resolved Matthias J. Sax
          15.
          		 Streams should not re-throw if suspending/closing tasks fails Sub-task Resolved Matthias J. Sax
          16.
          		 Task migration during rebalance callback process could lead the obsoleted task's IllegalStateException Sub-task Resolved Matthias J. Sax
          17.
          		 streams are not recovering from LockException during rebalancing Sub-task Resolved Unassigned
          18.
          		 Improve ProcessorStateManager exception handling Sub-task Resolved Matthias J. Sax
          19.
          		 User Callback Exceptions need to be handled properly Sub-task Resolved Matthias J. Sax

          Activity

            People

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

              Dates

                Created:
                Updated:
                Resolved: