yf created KAFKA-4102:
-------------------------

             Summary: Is kafka mirror maker in 0.10.X don't support mirror 
kafka 0.8.X?
                 Key: KAFKA-4102
                 URL: https://issues.apache.org/jira/browse/KAFKA-4102
             Project: Kafka
          Issue Type: Bug
            Reporter: yf
             Fix For: 0.10.1.0


FetchRequest@33437902 (kafka.consumer.ConsumerFetcherThread)
java.lang.IllegalArgumentException
        at java.nio.Buffer.limit(Buffer.java:275)
        at 
kafka.api.FetchResponsePartitionData$.readFrom(FetchResponse.scala:38)
        at kafka.api.TopicData$$anonfun$1.apply(FetchResponse.scala:100)
        at kafka.api.TopicData$$anonfun$1.apply(FetchResponse.scala:98)
        at 
scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
        at 
scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
        at scala.collection.immutable.Range.foreach(Range.scala:160)
        at scala.collection.TraversableLike$class.map(TraversableLike.scala:234)
        at scala.collection.AbstractTraversable.map(Traversable.scala:104)
        at kafka.api.TopicData$.readFrom(FetchResponse.scala:98)
        at kafka.api.FetchResponse$$anonfun$4.apply(FetchResponse.scala:170)
        at kafka.api.FetchResponse$$anonfun$4.apply(FetchResponse.scala:169)
        at 
scala.collection.TraversableLike$$anonfun$flatMap$1.apply(TraversableLike.scala:241)
        at 
scala.collection.TraversableLike$$anonfun$flatMap$1.apply(TraversableLike.scala:241)
        at scala.collection.immutable.Range.foreach(Range.scala:160)
        at 
scala.collection.TraversableLike$class.flatMap(TraversableLike.scala:241)
        at scala.collection.AbstractTraversable.flatMap(Traversable.scala:104)
        at kafka.api.FetchResponse$.readFrom(FetchResponse.scala:169)
        at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:135)
        at 
kafka.consumer.ConsumerFetcherThread.fetch(ConsumerFetcherThread.scala:108)
        at 
kafka.consumer.ConsumerFetcherThread.fetch(ConsumerFetcherThread.scala:29)
        at 
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:107)
        at 
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:98)
        at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63)



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to