<groupId>org.apache.storm</groupId> <artifactId>storm-kafka-client</artifactId> <version>2.1.0</version>
On Tue, Jul 21, 2020 at 10:38 PM Rui Abreu <[email protected]> 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 <[email protected]> > wrote: > >> 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 nextCommitOffset stored? >> Checked all consumer groups (since I didn't mention any specific group.id) >> but couldn't find this exact offset anywhere. >> >> Am I checking at the wrong place? >> >> Thanks, >> Rajat >> >
