Hi Robin,
Why would you expect it to start from the first message?
You're comitting the read offsets automatically every second. The offset is
persisted, next time you consume again, it will start at the persisted offset
again.
consumerProperties.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG,
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 :
