Description
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 flush task
Attachments
Issue Links
- is duplicated by
-
KAFKA-12182 Kafka connector is failing due to ' OffsetStorageWriter is already flushing' error
-
- Resolved
-
- links to