You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/02/21 20:24:00 UTC
[jira] [Updated] (KAFKA-7973) Allow a Punctuator to cancel its own
schedule
[ https://issues.apache.org/jira/browse/KAFKA-7973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Matthias J. Sax updated KAFKA-7973:
-----------------------------------
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:
{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]
was:
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]
> 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
> Priority: Minor
> Labels: needs-kip
>
> 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)