Unfortunately, it doesn't have that option in this version of Kafka! On Thu, Nov 23, 2017 at 9:02 PM, Brett Rann <br...@zendesk.com.invalid> wrote:
> I don't know about kafka-storm spout, but you could try using > the kafka-consumer-groups.sh cli to reset the offset. It has > a --reset-offsets option. > > On Thu, Nov 23, 2017 at 7:02 PM, Ali Nazemian <alinazem...@gmail.com> > wrote: > > > Hi All, > > > > I am using Kafka 0.10.0.2 and I am not able to upgrade my Kafka version. > I > > have a situation that after removing Kafka topic, I am getting the > > following error in Kafka-Storm Spout client because the offset hasn't > been > > reset properly. I was wondering how I can reset the offset in the > > new-consumer mode with this version of Kafka. Since I am using > > new-consumer, Kafka does not maintain offset info in Zookeeper. > > > > 2017-11-23 07:55:52.870 o.a.s.k.s.i.OffsetManager [WARN] > > topic-partition [indexing-1] has unexpected offset [7259]. Current > > committed Offset [8855387] > > > > > > Regards, > > Ali > > > -- A.Nazemian
