We're considering to use Kafka, and would like to know the Java/ Scala/Kafka version combination in which it is being used in production. The wiki "Operations" page states that "We are running Kafka 0.7 right now but may move to trunk as we fix bugs."
The reason is the console consumer deletes the previous state information from zookeeper when given the from-beginning option. So effectively only the 2nd consumer instance is alive. You can run ConsumerShell instead.
That makes perfect sense now... :) The console consumer is working just how I expect it to work now with that option removed from the command line.
On 4/19/13 10:31 AM, "Neha Narkhede" <[EMAIL PROTECTED]> wrote:
NEW: Monitor These Apps!
Apache Lucene, Apache Solr and all other Apache Software Foundation project and their respective logos are trademarks of the Apache Software Foundation.
Elasticsearch, Kibana, Logstash, and Beats are trademarks of Elasticsearch BV, registered in the U.S. and in other countries. This site and Sematext Group is in no way affiliated with Elasticsearch BV.
Service operated by Sematext