kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Tomas Niño Kehoe <tomasninoke...@gmail.com>
Subject Unable to commit to Kafka only in 0.8.2.1
Date Wed, 22 Jul 2015 21:33:42 GMT
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)

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message