Caused by: java.lang.IllegalArgumentException: Out of order offsets found in List

[rohit garg]

Hello Team ,

Recently i am facing this issue .

kafka.common.KafkaException: Error processing data for partition event-35
offset 22428196775
        at
kafka.server.AbstractFetcherThread.$anonfun$processFetchRequest$7(AbstractFetcherThread.scala:205)
        at scala.Option.foreach(Option.scala:257)
        at
kafka.server.AbstractFetcherThread.$anonfun$processFetchRequest$6(AbstractFetcherThread.scala:172)
        at
kafka.server.AbstractFetcherThread.$anonfun$processFetchRequest$6$adapted(AbstractFetcherThread.scala:169)
        at
scala.collection.mutable.ResizableArray.foreach(ResizableArray.scala:59)
        at
scala.collection.mutable.ResizableArray.foreach$(ResizableArray.scala:52)
        at
scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:48)
        at
kafka.server.AbstractFetcherThread.$anonfun$processFetchRequest$5(AbstractFetcherThread.scala:169)
        at
scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12)
        at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:217)
        at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:169)
        at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
        at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:64)
Caused by: java.lang.IllegalArgumentException: Out of order offsets found
in List(22428196775, 22428196776, 22428196777, 22428196778, 22428196779,
22428196780, 22428
196781, 22428196782, 22428196783, 22428196784, 22428196785, 22428196786,
22428196787, 22428196788,22428197974)
        at kafka.log.Log.$anonfun$append$2(Log.scala:683)
        at kafka.log.Log.maybeHandleIOException(Log.scala:1669)
        at kafka.log.Log.append(Log.scala:624)
        at kafka.log.Log.appendAsFollower(Log.scala:607)
        at
kafka.server.ReplicaFetcherThread.processPartitionData(ReplicaFetcherThread.scala:102)
        at
kafka.server.ReplicaFetcherThread.processPartitionData(ReplicaFetcherThread.scala:41)
        at
kafka.server.AbstractFetcherThread.$anonfun$processFetchRequest$7(AbstractFetcherThread.scala:184)
        ... 12 more
[2019-02-12 14:46:29,214] INFO [ReplicaFetcher replicaId=33, leaderId=114,
fetcherId=5] Stopped (kafka.server.ReplicaFetcherThread)


Thanks and Regards,
Rohit Garg