Ewen Cheslack-Postava created KAFKA-2742:
--------------------------------------------
Summary: 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)
