[ https://issues.apache.org/jira/browse/KAFKA-2742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14991938#comment-14991938 ]
ASF GitHub Bot commented on KAFKA-2742: --------------------------------------- Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/421 > SourceTaskOffsetCommitter does not properly remove commit tasks when they are > already in progress > ------------------------------------------------------------------------------------------------- > > Key: KAFKA-2742 > URL: https://issues.apache.org/jira/browse/KAFKA-2742 > Project: Kafka > Issue Type: Bug > Components: copycat > Reporter: Ewen Cheslack-Postava > Assignee: Ewen Cheslack-Postava > Fix For: 0.9.0.0 > > > The current implementation is relying on ScheduledExecutorService to cancel > the task, but this doesn't handle in-progress tasks and can result in > stopping source tasks not completing a final offset commit before considering > the task fully stopped. This can allow rebalancing to proceed before offsets > are fully committed. -- This message was sent by Atlassian JIRA (v6.3.4#6332)