Uploaded image for project: 'Samza'
  1. Samza
  2. SAMZA-571

Add task interface suppress uncaught exceptions

    XMLWordPrintableJSON

    Details

    • Type: Improvement
    • Status: Resolved
    • Priority: Major
    • Resolution: Won't Fix
    • Affects Version/s: 0.9.0
    • Fix Version/s: 0.10.0
    • Component/s: container
    • Labels:
      None

      Description

      When SystemProducer got a MessageSizeTooLargeException from Kafka broker, the container keeps trying and the job stucks at send call. The behavior in 0.9.0 will be different (i.e. the container will shutdown on exception). The SystemConsumer deserialization exception exhibit a similar behavior.

      It would be nice to add a ListenableTask interface w/ an onException() handler that allows the user to catch these exceptions and allow application logic on the exceptions.

        Attachments

          Activity

            People

            • Assignee:
              nickpan47 Yi Pan
              Reporter:
              nickpan47 Yi Pan
            • Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: