Hi, Is there any APIs in kafka that I can use to query how many messages there are under one topic? This topic already exist in Kafka server, and producer is sending messages to one topic in kafka server Sining Ma
A call through the Consumer Group, queuedMessageCount(topic, partitionNumber), could query zookeeper (and add the local fetched queue) to return this interesting piece of information. That is if we cannot already do this :)
Immediately monitoring. Later, possible thresholding to evoke a reconfiguration of the number of partitions into a new topic and migrate message index/logs and redirect pubs/subs to the new topic, during a traffic spike.
Yes, that's probably what you are looking for. It tells you the # of unconsumed messages per partition, for a particular consumer.
Jun On Fri, May 17, 2013 at 4:52 PM, Rob Withers <[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