Oleg Kuznetsov created KAFKA-5756:
-------------------------------------
Summary: Synchronization issue on flush
Key: KAFKA-5756
URL: https://issues.apache.org/jira/browse/KAFKA-5756
Project: Kafka
Issue Type: Bug
Components: KafkaConnect
Affects Versions: 0.10.2.0
Reporter: Oleg Kuznetsov
Access to OffsetStorageWriter#toFlush is not synchronized in doFlush() method,
whereas this collection can be accessed from 2 different threads:
- WorkerSourceTask.execute(), finally block
- SourceTaskOffsetCommitter, from periodic flushing task
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
