kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jun Rao <jun...@gmail.com>
Subject Re: Kafka Metrics in 0.8
Date Tue, 02 Jul 2013 14:35:08 GMT
In 0.8, there are more mbeans than 0.7.

Thanks,

Jun


On Mon, Jul 1, 2013 at 9:06 PM, Hanish Bansal <
hanish.bansal.agarwal@gmail.com> wrote:

> Okay i'll try for same.
>
> Also want to know that in kafka-0.7 there is single MBean -
> SocketServerStats which provides all kafka Metrics. But in Kafka-0-8 there
> are individual MBeans (like AllTopicsBytesInPerSec, AllTopicsBytesOutPerSec
> etc.) for getting each parameter like ByteInRate, ByteOutRate etc.
>
> Does kafka-0.8 provide any single MBean from which we can get all
> parameters?
>
>
>
>
> On Mon, Jul 1, 2013 at 3:47 PM, Jun Rao <junrao@gmail.com> wrote:
>
> > It seems that the mbean name that you used is wrong. The mbean names
> > registered by metrics 2.2.0 have quotes in them.
> >
> > Thanks,
> >
> > Jun
> >
> >
> > On Mon, Jul 1, 2013 at 4:31 AM, Hanish Bansal <
> > hanish.bansal.agarwal@gmail.com> wrote:
> >
> > > Hi
> > >
> > > I am getting various kafka parameters (like NumFetchRequests,
> > > FetchRequestsPerSecond, ProduceRequestsPerSecond etc.) through JMX in
> > case
> > > of kafka-0.7.
> > >
> > > In kafka-0.8 i am doing the same but not able to get parameters.
> > >
> > > There are some changes in reporting metrics in kafka-0.8 as compared to
> > > kafka-0.7. I have already noticed that. According to changes in
> > kafka-0.8 i
> > > am trying to get kafka metrics using JMX through jmxtrans api.
> > >
> > > Here is sample java code of getting jmx parameters using jmxtrans api:
> > >
> > >        Server kafkaJMXServer = new Server("127.0.0.1", "9999");
> > >         Query query1 = new Query();
> > >
> > >
> > >
> >
> query1.setObj("kafka.server:type=BrokerTopicMetrics,name=AllTopicsBytesInPerSec");
> > >         query1.addAttr("MeanRate");
> > >         kafkaJMXServer.addQuery(query1);
> > >         JmxProcess process = new JmxProcess(kafkaJMXServer);
> > >         JmxUtils.execute(process);
> > >         System.out.println(query1.getResults());
> > >
> > > Please let me know what i am missing?
> > >
> > > --
> > > *Thanks & Regards*
> > > *Hanish Bansal*
> > >
> >
>
>
>
> --
> *Thanks & Regards*
> *Hanish Bansal*
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message