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
from broker.
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
same work?

Navneet Sharma

NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB