[jira] [Created] (KAFKA-7973) Allow a Punctuator to cancel its own schedule

["Matthias J. Sax (JIRA)" <ji...@apache.org>]

Matthias J. Sax created KAFKA-7973:
--------------------------------------

             Summary: Allow a Punctuator to cancel its own schedule
                 Key: KAFKA-7973
                 URL: https://issues.apache.org/jira/browse/KAFKA-7973
             Project: Kafka
          Issue Type: Improvement
          Components: streams
            Reporter: Matthias J. Sax


As reported on this question on SO ([https://stackoverflow.com/questions/54803124/cancel-punctuator-on-kafka-streams-after-is-triggered)] if one registers a lot of punctuation one needs to track them manually if they should be cancel at some point, what can be tedious.

It might be a good addition, to allow a `Punctuator` to cancel itself. Something like:
{quote}void punctuate(long timestamp) {
    // do stuff
    if (...) {
        this.cancel();
    }
}{quote}
It's just a sketch of an idea. This ticket implies a public API change and requires to write a KIP: [https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals]



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)