Re: where is nextCommitOffset stored?

org.apache.storm storm-kafka-client 2.1.0 On Tue, Jul 21, 2020 at 10:38 PM Rui Abreu wrote: > Old Kafka consumers stored the commit offset in Zookeeper. Which version > are you using? > > On Tue, 21 Jul 2020 at 10:54, Rajat Gangwar > wrote: > >> Hi, >> >> I am seeing following error in Storm l

Re: where is nextCommitOffset stored?

Old Kafka consumers stored the commit offset in Zookeeper. Which version are you using? On Tue, 21 Jul 2020 at 10:54, Rajat Gangwar wrote: > Hi, > > I am seeing following error in Storm logs: > > java.lang.IllegalStateException: The offset [2] is below the current > *nextCommitOffset* [*5270353*

where is nextCommitOffset stored?

Hi, I am seeing following error in Storm logs: java.lang.IllegalStateException: The offset [2] is below the current *nextCommitOffset* [*5270353*] for [replication-0]. This should not be possible, and likely indicates a bug in the spout's acking I need to know where is the current nextCommitOffs