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 >
