XMLWordPrintableJSON

    Details

    • Type: Sub-task
    • Status: Resolved
    • Priority: Major
    • Resolution: Duplicate
    • Affects Version/s: 0.11.0.0
    • Fix Version/s: None
    • Component/s: streams
    • Labels:
      None

      Description

      Used in StreamsThread.java, mostly to .poll() but also to restore data.
      Used in StreamsTask.java, mostly to .pause(), .resume()

      All exceptions here are currently caught all the way up to the main running loop in a broad catch(Exception e) statement in StreamThread.run().

      One main concern on the consumer path is handling deserialization errors that happen before streams has even had a chance to look at the data: https://issues.apache.org/jira/browse/KAFKA-5157

        Attachments

          Issue Links

            Activity

              People

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

                Dates

                • Created:
                  Updated:
                  Resolved: