Jagadish created SAMZA-934:
------------------------------
Summary: Race condition in Kafka System Producer
Key: SAMZA-934
URL: https://issues.apache.org/jira/browse/SAMZA-934
Project: Samza
Issue Type: Bug
Reporter: Jagadish
Assignee: Navina Ramesh
There is a race condition in the KafkaSystemProducer class in the access to the
sendFailed flag. (in the main and the callback threads). It is possible for a
A. a failure to be masked
B. a failure to repeatedly re-throw exceptions in a loop, by the write to this
flag by another thread.
Ideally, failure should immediately shut down the producer in the *same*
callback thread. This will cancel future sends / buffered sends in the
producer.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
