[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16811681#comment-16811681
]
Ted Yu commented on KAFKA-5998:
---
I made the following change:
{code}
diff --git
a/streams/
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16811611#comment-16811611
]
Mohan Parthasarathy edited comment on KAFKA-5998 at 4/6/19 3:03 PM:
---
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16811611#comment-16811611
]
Mohan Parthasarathy commented on KAFKA-5998:
Ted, Thanks for your suggestion.
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16811603#comment-16811603
]
Ted Yu commented on KAFKA-5998:
---
It seems StreamTask can keep track of active tasks. After
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16811551#comment-16811551
]
Ted Yu edited comment on KAFKA-5998 at 4/6/19 10:55 AM:
Cleanup d
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16811551#comment-16811551
]
Ted Yu commented on KAFKA-5998:
---
Cleanup delay is controlled by:
{code}
public static f
