[
https://issues.apache.org/jira/browse/KAFKA-5756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689450#comment-17689450
]
Chris Egerton edited comment on KAFKA-5756 at 2/16/23 2:53 AM:
---------------------------------------------------------------
I've merged Greg's fix and updated the fix version to 3.5.0, since this issue
was not fully addressed before that fix.
I've also backported to the 3.3 and 3.4 branches. It should be available in the
next releases for each of those.
was (Author: chrisegerton):
I've merged Greg's fix and updated the fix version to 3.5.0, since this issue
was not fully addressed before that fix.
I'll backport to 3.3 and 3.4 sometime in the next day or so.
> 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
> Assignee: Greg Harris
> Priority: Major
> Fix For: 3.5.0, 3.4.1, 3.3.3
>
>
> 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
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
