Hu is correct, there isn't anything currently, but there is an active proposal: https://cwiki.apache.org/confluence/display/KAFKA/KIP-122%3A+Add+Reset+Consumer+Group+Offsets+tooling
On Wed, May 3, 2017 at 1:23 PM Hu Xi <[email protected]> wrote: > Seems there is no command line out of box, but if you could write a simple > Java client application that firstly calls 'seek' or 'seekToBeginning' to > reset offsets to what you expect and then invoke commitSync to commit the > offsets. > > > ________________________________ > 发件人: Paul van der Linden <[email protected]> > 发送时间: 2017年5月3日 18:28 > 收件人: [email protected] > 主题: Resetting offsets > > I'm trying to reset the offsets for all partitions for all topics for a > consumer group, but I can't seem to find a working way. > > The command line tool provides a tool to remove a consumer group (which > would be fine in this occasion), but this is not working with the "new" > style consumer groups. I tried to set consumer offsets with a client, which > also didn't work (we are using confluent-kafka-python with librdkafka). > > Is there any way to reset the offsets (preferable with python or a command > line tool)? > > Thanks >
