Cancelling Scheduled Punctuator after a single iteration about kafka-streams-examples HOT 7 CLOSED

@viktorjucas Yes, note that ProcessorContex#schedule returns a Cancellable event. You can cancel it even within the punctuate call. For example:

Cancellable scheduled;
scheduled = context.schedule(... timestamp -> scheduled.cancel);

from kafka-streams-examples.

I have tried that and it doesn't seem to be cancelling.

public class Transformer implements Transformer<> {
    private ProcessorContext context;
    private Cancellable scheduled;

    @Override
    public void init(PorcessorContext processContext) {
        this.context = processorContext;
        scheduled = context.schedule(TimeUnit.SECONDS.toMillis(5), PunctuationType.WALL_CLOCK_TIME,
                                     this::punctuateCancel);
    }

    private void punctuateCancel(long timestamp) {
        scheduled.cancel();
    }
}

from kafka-streams-examples.

Which version are you using? Note that this functionality is fixed in 1.1.1: https://issues.apache.org/jira/browse/KAFKA-6748

from kafka-streams-examples.

That's the reason. I was using 1.1.0.

from kafka-streams-examples.

Closed prematurely.

Is v1.1.1 available through Maven already?

from kafka-streams-examples.

No it is not released out yet: https://mvnrepository.com/artifact/org.apache.kafka/kafka-streams

If you have to cancel the even within the punctuate call, you can consider backporting that fix into your source code build.

from kafka-streams-examples.

@viktorjucas Kafka 1.1.1 is released now. Can you try it out and verify the fix so we can close this issue?

from kafka-streams-examples.