Lakshmi Manasa Gaduputi created SAMZA-2515:
----------------------------------------------

             Summary: Thread safety for kafka consumer in KafkaConsumerProxy
                 Key: SAMZA-2515
                 URL: https://issues.apache.org/jira/browse/SAMZA-2515
             Project: Samza
          Issue Type: Bug
            Reporter: Lakshmi Manasa Gaduputi
            Assignee: Lakshmi Manasa Gaduputi


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. 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to