Return all messages in a range

Hi everyone,
My problem is this: I want all messages in a certain time interval and I want to terminate the process when there are no more messages in that interval.
I’ve used “Stream Processor” but I don’t figure out how to end my process.

Kafka Streams might not be a good fit for this case: it does not allow to auto-terminate itself.

If you only want to get the messages, it might be easier to use a plain KafakConsumer.

1 Like