[KAFKA-7973] Allow a Punctuator to cancel its own schedule

• Type: Improvement
• Status: Open
• Priority: Minor
• Resolution: Unresolved
• Component/s: streams
• Labels: needs-kip
• Assignee: Unassigned
• Reporter: Matthias J. Sax
• Created: 21/Feb/19 19:42
• Updated: 22/Feb/19 00:19

Description

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:

public void punctuate(final long timestamp) {
  // business logic
  if (...) {
    this.cancel();
  }
}

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