Thanks Jun
On Tue, Jul 2, 2013 at 2:35 PM, Jun Rao <jun...@gmail.com> wrote:
> 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.agar...@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 <jun...@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.agar...@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*
> >
>
--
*Thanks & Regards*
*Hanish Bansal*
