You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@samza.apache.org by "Navina Ramesh (JIRA)" <ji...@apache.org> on 2015/03/23 19:30:52 UTC

[jira] [Created] (SAMZA-610) Fail container (without send retry) when Kafka producer throws a RetriableException

Navina Ramesh created SAMZA-610:
-----------------------------------

             Summary: Fail container (without send retry) when Kafka producer throws a RetriableException
                 Key: SAMZA-610
                 URL: https://issues.apache.org/jira/browse/SAMZA-610
             Project: Samza
          Issue Type: Bug
            Reporter: Navina Ramesh


With the new Java-based Kafka producer, we get 2 kinds of exceptions - RetriableException & Non-RetriableException.
We have set max.retries to INT_MAX. This means that if the producer throws a RetriableException, it has already retried the send request. At the Samza level, we just have to fail the container in order to avoid re-ordering of messages. Currently, we try from the Samza layer, which should not be necessary. 



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