[
https://issues.apache.org/jira/browse/KAFKA-10362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17189831#comment-17189831
]
Sharath Bhat commented on KAFKA-10362:
--------------------------------------
Hi [~ipasynkov],
Can I continue work on this ticket ?
I am newbie to kafka community, so I thought this would be a place to start and
have raised the PR.
Please let me know your thoughts.
> When resuming Streams active task with EOS, the checkpoint file should be
> deleted
> ---------------------------------------------------------------------------------
>
> Key: KAFKA-10362
> URL: https://issues.apache.org/jira/browse/KAFKA-10362
> Project: Kafka
> Issue Type: Bug
> Components: streams
> Affects Versions: 2.6.0
> Reporter: Guozhang Wang
> Priority: Major
> Labels: newbie++
>
> Today when we suspend a task we commit and along with the commit we always
> write checkpoint file even if we are eosEnabled (since the state is already
> SUSPENDED). But the suspended task may later be resumed and in that case the
> checkpoint file should be deleted since it should only be written when it is
> cleanly closed.
> With our latest rebalance protocol in KIP-429, resume would not be called
> since all suspended tasks would be closed, but with the old eager protocol it
> may still be called — I think that may be the reason we did not get it often.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)