[ https://issues.apache.org/jira/browse/SAMZA-1019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Boris Shkolnik updated SAMZA-1019: ---------------------------------- Attachment: SAMZA-1019.1.patch new patch. > reopen a Kafka system producer if send() method is called again > --------------------------------------------------------------- > > Key: SAMZA-1019 > URL: https://issues.apache.org/jira/browse/SAMZA-1019 > Project: Samza > Issue Type: Bug > Affects Versions: 0.11 > Reporter: Boris Shkolnik > Assignee: Boris Shkolnik > Attachments: SAMZA-1019.0.patch, SAMZA-1019.1.patch > > > Normally, when a kafka system producer runs into an issue during a send() > call and throws an exception, it causes the container to shutdown. > But if the client issues another producer.send(), after the producer has > thrown an exception, it means that the user caught the exception and decided > to continue. So we will reopen the producer. -- This message was sent by Atlassian JIRA (v6.3.4#6332)