[SAMZA-2515] Thread safety for kafka consumer in KafkaConsumerProxy

• Type: Bug
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 1.5
• Assignee: Lakshmi Manasa Gaduputi
• Reporter: Lakshmi Manasa Gaduputi
• Created: 23/Apr/20 18:58
• Updated: 27/May/20 03:39
• Resolved: 28/Apr/20 14:27

Description

Container failures were noticed due to ConcurrentModificationException thrown from KafkaConsumer.

This is due to use of the consumer without a synchronized block in one method of KafkaConsumerProxy.