You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by Tomas Niño Kehoe <to...@gmail.com> on 2015/07/22 23:33:42 UTC

Unable to commit to Kafka only in 0.8.2.1

HI,

I'm using a single consumer in a consumer group, with this configuration

group.id = hugogroupenkafka
auto.commit.enable = false
dual.commit.enabled = false
offsets.storage=kafka

This consumer receives messages from the topic successfully, however, when
I try to commit the offsets by doing connector.commitOffsets, I get this
exception (every time) [1].

Is there anything special I need to do to store offsets in Kafka
exclusively?

Thanks in advance,
Tomás

[1]
Error while committing offsets. (kafka.consumer.ZookeeperConsumerConnector)
java.io.EOFException
    at
org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:83)
    at
org.apache.kafka.common.network.NetworkReceive.readCompletely(NetworkReceive.java:114)
    at kafka.network.BlockingChannel.receive(BlockingChannel.scala:121)
    at
kafka.consumer.ZookeeperConsumerConnector.liftedTree2$1(ZookeeperConsumerConnector.scala:337)
    at
kafka.consumer.ZookeeperConsumerConnector.commitOffsets(ZookeeperConsumerConnector.scala:334)
    at
kafka.consumer.ZookeeperConsumerConnector.commitOffsets(ZookeeperConsumerConnector.scala:314)
    at
kafka.consumer.ZookeeperConsumerConnector.commitOffsets(ZookeeperConsumerConnector.scala:303)
    at
kafka.tools.ConsoleConsumer$$anonfun$main$1.apply(ConsoleConsumer.scala:181)
    at
kafka.tools.ConsoleConsumer$$anonfun$main$1.apply(ConsoleConsumer.scala:177)
    at scala.collection.Iterator$class.foreach(Iterator.scala:727)
    at kafka.utils.IteratorTemplate.foreach(IteratorTemplate.scala:32)
    at scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
    at kafka.consumer.KafkaStream.foreach(KafkaStream.scala:25)
    at kafka.tools.ConsoleConsumer$.main(ConsoleConsumer.scala:177)
    at kafka.tools.ConsoleConsumer.main(ConsoleConsumer.scala)