I try to resolve such behavior:
    suppose storm consumes messages from kafka. In case part of it's
consumers crashed for any reasons and as a result didn't succeed to process
the consumed messages. But if it is impossible after recover to reprocess
these messages the system will not be robust and it has data integrity

That is why I try to understand what is the Kafka capabilities. I just
don't know what is the best practice to do it.
May be it is a matter of configuration ?

Please advice.
On Thu, Aug 1, 2013 at 1:31 AM, Milind Parikh <[EMAIL PROTECTED]>wrote:
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