Hi All,
As kafka-0.8's main feature in data replication.
We are running two kafka nodes(lets say: kafka-1 and kafka-2) in cluster
mode. If we produce data into kafka using replication factor=2 then its
replica is created on second machine.
I am using jconsole to monitor kafka. if messages are going on kafka-1 then
i am able to see kafka metrics on jconsole of kafka-1. But by connecting to
jconsole for kafka-2 i am not seeing any metrics, i want to know why it is
happening ??
For more clarity i am asking same question in other way:
If one kafka node is storing replicas of data, then will it be visible on
jconsole or not ?
On Wed, Jul 3, 2013 at 1:06 PM, Hanish Bansal <
hanish.bansal.agar...@gmail.com> wrote:
> 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*
>
--
*Thanks & Regards*
*Hanish Bansal*
