kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ben Drees <ben.dr...@gmail.com>
Subject Best way to erase consumer state
Date Fri, 05 Dec 2014 06:55:47 GMT

What is the best way to erase a stopped, multiprocess consumer's state so
that it can be reset (to "smallest offsets", for example) when the consumer
is restarted?  Deleting /consumers/<group-name> from Zookeeper has had the
desired effect in the past, but I ran into a situation today where some of
the consumer processes jumped to the desired offsets (in this case
"largest") on restart but others did not.  I'm not sure whether the issue
was replication lag across the Zookeeper cluster or cached state in Kafka.
I’m using kafka-python.


  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message