[ https://issues.apache.org/jira/browse/KAFKA-3850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jason Gustafson updated KAFKA-3850: ----------------------------------- Status: Patch Available (was: Open) > WorkerSinkTask should retry commits if woken up during rebalance or shutdown > ---------------------------------------------------------------------------- > > Key: KAFKA-3850 > URL: https://issues.apache.org/jira/browse/KAFKA-3850 > Project: Kafka > Issue Type: Bug > Components: KafkaConnect > Affects Versions: 0.10.0.0 > Reporter: Jason Gustafson > Assignee: Jason Gustafson > Fix For: 0.10.0.1 > > > We use consumer.wakeup() to interrupt long polls when we need to pause/resume > partitions and when we shutdown sink tasks. The resulting {{WakeupException}} > could be raised from the synchronous commit which we use in between > rebalances and on shutdown. Since we don't currently catch this exception, we > can fail to commit offsets, which typically results in duplicates. To fix > this problem, we should catch the exception, retry the commit, and then > rethrow it. -- This message was sent by Atlassian JIRA (v6.3.4#6332)