Hello, Is there a way to retrieve all new messages from a Kafka queue and know when there we've gotten them all? What I'm looking to do is write a simple consumer that runs periodically and captures all of the messages that have been stored in Kafka since it was last ran.
Btw: I'm doing this in Java and would prefer to only have to interface with
Java classes vs. Scala classes, but I can make due if that's not possible.
Casey
