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)