You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by "Yi Pan (Data Infrastructure) (JIRA)" <ji...@apache.org> on 2016/04/21 07:23:25 UTC

[jira] [Updated] (SAMZA-911) Abandon producer retry after a certain # of errors

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

Yi Pan (Data Infrastructure) updated SAMZA-911:
-----------------------------------------------
    Fix Version/s: 0.10.1

> Abandon producer retry after a certain # of errors
> --------------------------------------------------
>
>                 Key: SAMZA-911
>                 URL: https://issues.apache.org/jira/browse/SAMZA-911
>             Project: Samza
>          Issue Type: Bug
>            Reporter: Jagadish
>            Assignee: Jagadish
>             Fix For: 0.10.1
>
>         Attachments: SAMZA-911.0.patch
>
>
> Currently, the KafkaSystemProducer's  producer loop keeps retrying indefinitely when there is an exception in the retryBackOff loop. If there are repeated exceptions, then it makes sense to retry for awhile, and then fail the container. 
> Long term, we should focus on getting rid off the retryBackOff loop, and close the producer object in the callback during failure. This will guarantee in-order delivery.



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