Hello Trevor,
You may be interested in the punctuate API of the processor:
https://kafka.apache.org/0110/javadoc/index.html?org/apache/kafka/streams/processor/Processor.html#punctuate
Note that in the coming 1.0.0 version users can schedule a punctuate
function either based on stream time
I have a sneaky suspicion this is out of scope for Kafka Streams, however I
thought it wouldn't hurt to ask... I'm trying to implement a temperature
monitoring system. Kafka Streams seems great for doing that. The one
scenario that I'm not able to cover, however, is detecting when a
temperature
