Hello,

I have a couple questions about consumers.

1) What's the preferred method of writing a consumer?  The SimpleConsumer or 
the Zookeeper consumer?  I'm guessing the Zookeeper one allows the consumer to 
handle failures within the Kafka cluster.  E.g. If one node goes down, the 
consumer will then pull from the replicated node.

2) What's the proper way to track which messages have been processed by a 
consumer?  The scenario I'm looking at is if a consumer dies and we later 
restart it.  What we don't want happening is the consumer re-processing records 
that have already been processed.

What I'm basically looking for are best practices for setting up a system where 
we have to handle a high-volume of traffic.

Thanks.

Casey

Reply via email to