Xinyu Liu created SAMZA-960:
-------------------------------
Summary: Make system producer thread safe
Key: SAMZA-960
URL: https://issues.apache.org/jira/browse/SAMZA-960
Project: Samza
Issue Type: Sub-task
Reporter: Xinyu Liu
Assignee: Xinyu Liu
All the system producers need to be thread safe in order to be used in
multithreaded tasks. The following are the changes:
- In KafkaSystemProducer, remove the buggy retry logic and treat any exception
as fatal.
- In HdfsSystemProducer, add synchronization lock to all public methods.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
