Clojurians Log v2

Say you have a consumer assigned to a parition and the consumer crashes, but the offset of the partition moves on (as data is being feed into the topic). If the consumer restarts, then seek to end will skip past all the messages that have been received in the meantime

How do you, in Jackdaw, say, go back to the current offset of the consumer group and resume from there?

If you don't seek then by default the consumer will start at the last committed offset.

https://kafka.apache.org/25/javadoc/index.html?org/apache/kafka/clients/consumer/KafkaConsumer.html (see section titled "Offsets and Consumer Position")

ah right, so if seek is not defined, then it'll resume.

mucho gracious!

perfect - working! thanks @cddr! 🙂