79565242

Date: 2025-04-09 20:00:20
Score: 1
Natty:
Report link

...answering my own question. It looks like auto commit for the confluent_kafka consumer does not mean that commit is called on object desctruction; I have to explicitly call the close method on my consumer to make sure that offsets are committed.

I'm still a little perplexed that it didn't just start over from the beginning when I ran it the second time, but at least I can get it to work.

Reasons:
  • Has code block (-0.5):
  • Self-answer (0.5):
  • Low reputation (1):
Posted by: Rob Knop