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

["Yi Pan (Data Infrastructure) (JIRA)" <ji...@apache.org>]

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

Yi Pan (Data Infrastructure) resolved SAMZA-571.
------------------------------------------------
    Resolution: Won't Fix

Closing due to issues revealed in the tests.

> 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)
>            Assignee: Yi Pan (Data Infrastructure)
>             Fix For: 0.10.0
>
>
> 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)