Is it the last parameter of SimpleConsumer (leadBroker, a_port, soTimeOut, buffer_size, clientName) ? (i.e. clientName) Maybe I did something wrong, but I ran two consumers with same "clientName" and still both consumers received exactly same amount and same data from Kafka while it is supposed that the data is divided between these two consumers (due to load balancing)!
best, /Shahab On Wed, Feb 19, 2014 at 5:46 PM, Guozhang Wang <[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