[SAMZA-960] Make system producer thread safe

• Type: Sub-task
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Assignee: Xinyu Liu
• Reporter: Xinyu Liu
• Created: 03/Jun/16 17:19
• Updated: 20/Jul/16 20:25
• Resolved: 20/Jul/16 20:25

Description

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.