Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-7973

Allow a Punctuator to cancel its own schedule

    XMLWordPrintableJSON

    Details

    • Type: Improvement
    • Status: Open
    • Priority: Minor
    • Resolution: Unresolved
    • Affects Version/s: None
    • Fix Version/s: None
    • Component/s: streams
    • Labels:

      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

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              mjsax Matthias J. Sax
            • Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

              • Created:
                Updated: