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

Options for handling exceptions in streams

    XMLWordPrintableJSON

    Details

    • Type: Task
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 0.10.2.0
    • Fix Version/s: 1.1.0
    • Component/s: streams
    • Labels:

      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

          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

              • Assignee:
                mjsax Matthias J. Sax
                Reporter:
                enothereska Eno Thereska
              • Votes:
                4 Vote for this issue
                Watchers:
                14 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: