You need to configure each producer with a different client.id. Thanks,
Jun On Thu, May 29, 2014 at 5:38 PM, Bhavesh Mistry <mistry.p.bhav...@gmail.com> wrote: > We have 4 producers (for 4 topics) within one JVM and all of them > configured with same broker list. Each one of the producer has client.id > configured as topic name. When I see the JMX console, I see that " > *ProducerRequestMetric*" JMX have issue, it takes the last client.id > config > and report the metrics. > > 1) Does it really report the Request rate per producer or all the > producers to all the brokers (*AllBrokersProducerRequestRateAndTimeMs or > AllBrokersProducerRequestSize *) Is it like global aggregated Request > rate and size across all topics for All Brokers ? > > 2) Similarly under "*ProducerTopicMetrics*", AllTopicsBytesPerSec , > AllTopicsDroppedMessagesPerSec, AllTopicsMessagesPerSec are per topic or > across all topics ? The numbers for AllTopics* are same as per topoic > (logmon.error-*) ? Can you guys please clarify this ? Do you guys > intended to work as global aggregated for ALL topic ? > > Please see the following image: > > > > > > Thanks, > Bhavesh > > > On Wed, May 28, 2014 at 9:44 PM, Jun Rao <jun...@gmail.com> wrote: > > > The producer has a "failedToSend" jmx, which includes all kinds of > errors. > > We don't have the message rate per partition. > > > > Thanks, > > > > Jun > > > > > > On Wed, May 28, 2014 at 11:41 AM, Bhavesh Mistry < > > mistry.p.bhav...@gmail.com > > > wrote: > > > > > Hi Kafka Group, > > > > > > I need to get following metrics from the producer side. > > > > > > I am able to get following metric using the ProducerTopicMetrics class > > per > > > minute. > > > messageRate > > > byteRate > > > droppedMessageRate > > > > > > I would like to know how to get above metric per topic per partition. > > > Also, how do I get count of number of exception occurred due to > > > kafka.common.MessageSizeTooLargeException, or Network > > > Down or message rejected due to Broker being down etc. Is there a > JMX > > or > > > any other bean to get this metric counter ? > > > > > > We are using Kafka version 0.8.0 > > > > > > Thanks, > > > > > > Bhavesh > > > > > >
