Hello everybody, I'm testing the new 0.9.0.1 API and I try to make a basic example working.
*Java code* : *Consumer *: http://pastebin.com/YtvW0sz5 *Producer *: http://pastebin.com/anQay9YE *Test* : http://pastebin.com/nniYLsHL *Kafka configuration* : *Zookeeper propertie*s : http://pastebin.com/KC5yZdNx *Kafka properties* : http://pastebin.com/Psy4uAYL But when I try to run my test and restart Kafka to see what happen. The Consumer doesn't always consume first messages. Sometimes it consume messages at offset 0 or 574 or 1292 ... The behavior of the test seems to be very random. Anybody have an idea on that issue ? Best Regards, Robin
