I am trying to use the code supplied in hadoop-consumer package. I am
running into following issues:
1) This code is using SimpleConsumer which is actually contacting Kafka
Broker without Zookeeper. Because of which messages are not getting cleared
And i am getting duplicate messages in each run.
2) The retention policy specified as log.retention.hours in
server.properties is not working. Not sure if its due to SimpleConsumer.
Is it expected behaviour. Is there any code using high level consumer for