Unable to commit to Kafka only in 0.8.2.1

2015-07-22 Thread Tomas Niño Kehoe
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

Retrieving lost messages produced while the consumer was down.

2015-07-21 Thread Tomas Niño Kehoe
Hi, We've been using Kafka for a couple of months, and now we're trying to to write a Simple application using the ConsumerGroup to fully understand Kafka. Having the producer continually writing data, our consumer occasionally needs to be restarted. However, once the program is brought back up,