[jira] [Created] (KAFKA-7769) Illegal batch type class

["Asaf Mesika (JIRA)" <ji...@apache.org>]

Asaf Mesika created KAFKA-7769:
----------------------------------

             Summary:  Illegal batch type class
                 Key: KAFKA-7769
                 URL: https://issues.apache.org/jira/browse/KAFKA-7769
             Project: Kafka
          Issue Type: Bug
          Components: consumer
    Affects Versions: 1.1.0
         Environment: Kafka 1.1.0 on client side, running on Java 8
Kafka 1.1.0 on broker side, running on Java 8
            Reporter: Asaf Mesika


I get the following exception from Kafka Consumer version 1.1.0:
{code:java}
kafka.common.KafkaException: Error processing data for partition acmetopic-24 offset 1408742703 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:169) at kafka.server.AbstractFetcherThread.$anonfun$processFetchRequest$6$adapted(AbstractFetcherThread.scala:166) at scala.collection.Iterator.foreach(Iterator.scala:929) at scala.collection.Iterator.foreach$(Iterator.scala:929) at scala.collection.AbstractIterator.foreach(Iterator.scala:1417) at scala.collection.IterableLike.foreach(IterableLike.scala:71) at scala.collection.IterableLike.foreach$(IterableLike.scala:70) at scala.collection.AbstractIterable.foreach(Iterable.scala:54) at kafka.server.AbstractFetcherThread.$anonfun$processFetchRequest$5(AbstractFetcherThread.scala:166) at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12) at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:250) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:166) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82) Caused by: java.lang.IllegalArgumentException: Illegal batch type class org.apache.kafka.common.record.DefaultRecordBatch. The older message format classes only support conversion from class org.apache.kafka.common.record.AbstractLegacyRecordBatch, which is used for magic v0 and v1 at kafka.message.MessageAndOffset$.fromRecordBatch(MessageAndOffset.scala:30) at kafka.message.ByteBufferMessageSet.$anonfun$internalIterator$1(ByteBufferMessageSet.scala:169) at scala.collection.Iterator$$anon$10.next(Iterator.scala:448) at scala.collection.Iterator.toStream(Iterator.scala:1403) at scala.collection.Iterator.toStream$(Iterator.scala:1402) at scala.collection.AbstractIterator.toStream(Iterator.scala:1417) at scala.collection.TraversableOnce.toSeq(TraversableOnce.scala:298) at scala.collection.TraversableOnce.toSeq$(TraversableOnce.scala:298) at scala.collection.AbstractIterator.toSeq(Iterator.scala:1417) at kafka.consumer.PartitionTopicInfo.enqueue(PartitionTopicInfo.scala:59) at kafka.consumer.ConsumerFetcherThread.processPartitionData(ConsumerFetcherThread.scala:87) at kafka.consumer.ConsumerFetcherThread.processPartitionData(ConsumerFetcherThread.scala:37) at kafka.server.AbstractFetcherThread.$anonfun$processFetchRequest$7(AbstractFetcherThread.scala:183) ... 15 common frames omitted{code}
 

It happens once in  a while. I initialise the client with zooKeeper connect, and not with bootstrap servers. 

Any idea what can cause this?

 

 

 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)