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)