kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jonathan Santilli <jonathansanti...@gmail.com>
Subject Re: Caused by: java.lang.IllegalArgumentException: Out of order offsets found in List
Date Tue, 12 Feb 2019 10:24:06 GMT
Hello Rohit,

maybe is better to fill a JIRA with some context, details and how to
reproduce it? like this is kind of difficult to detect the root cause
unless another person in the list actually can provide some insights with
the provided information.


Cheers!
--
Jonathan


On Tue, Feb 12, 2019 at 10:18 AM rohit garg <rohit.garg41@gmail.com> wrote:

> 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
>


-- 
Santilli Jonathan

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message