Hi,

my kafka client is still with kafka jars - 0.8.2.1
and server updated with - 0.10.0.1

I configured server with :
inter.broker.protocol.version=0.8.2.1
log.message.format.version=0.8.2.1

I'm getting below error on commit offset.
here auto commit is disabled.
Is there any other configurations that I need to take care to fix this.

ERROR kafka.consumer.ZookeeperConsumerConnector:
[zohocrm_172_20_2_23_hadoop_tables_172.20.6.248-1486730164723-67176e62],
Error while committing offsets.
java.io.EOFException: Received -1 when reading from channel, socket has
likely been closed.
        at kafka.utils.Utils$.read(Utils.scala:381)
        at
kafka.network.BoundedByteBufferReceive.readFrom(BoundedByteBufferReceive.scala:54)
        at kafka.network.Receive$class.readCompletely(Transmission.scala:56)
        at
kafka.network.BoundedByteBufferReceive.readCompletely(BoundedByteBufferReceive.scala:29)
        at kafka.network.BlockingChannel.receive(BlockingChannel.scala:111)
        at
kafka.consumer.ZookeeperConsumerConnector.liftedTree2$1(ZookeeperConsumerConnector.scala:313)
        at
kafka.consumer.ZookeeperConsumerConnector.commitOffsets(ZookeeperConsumerConnector.scala:310)
        at
kafka.javaapi.consumer.ZookeeperConsumerConnector.commitOffsets(ZookeeperConsumerConnector.scala:111)
        at
com.zoho.mysqlbackup.kafka.consumer.KafkaHLConsumer.commitOffset(KafkaHLConsumer.java:173)
        at
com.zoho.mysqlbackup.kafka.consumer.KafkaHLConsumer.run(KafkaHLConsumer.java:271)

Reply via email to