One thing might worth checking is the offset.storage value in your
consumer config. Is it set to ³kafka² or ³zookeeper² for you consumer? If
the offset is set to kafka, then the offset will be stored in the offset
topic in Kafka instead of in zookeeper. So deleting zookeeper path won¹t
work for tho
Hi,
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/ from Zookeeper has had the
desired effect in the past, but I ran into a situation today where some of
the co
