[jira] [Updated] (SAMZA-571) Add task interface suppress uncaught exceptions

["Chris Riccomini (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/SAMZA-571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Chris Riccomini updated SAMZA-571:
----------------------------------
    Summary: Add task interface suppress uncaught exceptions  (was: Would be nice to have a ListenableTask interface to allow users to catch and react to system consumer/producer  exceptions)

> Add task interface suppress uncaught exceptions
> -----------------------------------------------
>
>                 Key: SAMZA-571
>                 URL: https://issues.apache.org/jira/browse/SAMZA-571
>             Project: Samza
>          Issue Type: Improvement
>          Components: container
>    Affects Versions: 0.9.0
>            Reporter: Yi Pan (Data Infrastructure)
>
> 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.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)