+ 1! 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 :)
Thanks, rob > -----Original Message----- > From: Sining Ma [mailto:sinin...@aol.com] > Sent: Wednesday, May 15, 2013 7:05 PM > To: users@kafka.apache.org > Subject: API to to query messages amount under one topic > > 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 > > > -- Regards > Sining Ma >
