[kasey_junk]

A common pattern is to publish a "checkpoint" message. Not sure if the concept is built into Kafka or not.