Hi there,

I've been reading through the Kafka Streams documentation and there seems
to be a tricky limitation that I'd like to make sure I've understood
correctly.

The docs[1] talk about the `punctuate` callback being based on stream time
and that all incoming partitions of all incoming topics must have
progressed through the minimum time interval for `punctuate` to be called.

This seems to be like a problem for situations where you have one very fast
and one very slow stream being processed together, for example joining a
fast-moving KStream to a slow-changing KTable.

Have I misunderstood something or is this relatively common use case not
supported with the `punctuate` callback?

Many thanks,
Elliot

[1]
http://docs.confluent.io/3.1.2/streams/developer-guide.html#defining-a-stream-processor
(see the "Attention" box)

Reply via email to