Re: Kafka 2.1.0 JMX mbean broken ?

2019-03-12 Thread Raghav
Hi ManiKumar Can you suggest any Java api snippet code that does this ? I tried something like this but could not get it to work. I am seeking help only after trying everything that I could. Breaking backward compatibility is tough for many customers like us, unless there is a better and a new

Re: Kafka 2.1.0 JMX mbean broken ?

2019-03-08 Thread Manikumar
Hi Raghav, As you know, KIP-372 added "version" tag to RequestsPerSec metric to monitor requests for each version. As mentioned in the KIP, to get total count per request (across all versions), we need to aggregate over all versions. You may need to automate this by fetching all metrics using

Re: Kafka 2.1.0 JMX mbean broken ?

2019-03-08 Thread Raghav
Hello Allen, Ted, Mani, Gwen, James https://www.mail-archive.com/dev@kafka.apache.org/msg86226.html I read this email thread and I see that you guys were split in going ahead with this change. This has broken our dashboard in 2.1 Kafka, which is ok as long as we know how to fix it. Can you

Re: Kafka 2.1.0 JMX mbean broken ?

2018-12-14 Thread Raghav
I got it to work. I fired up a console and then saw what beans are registered there and then queries using the code. It works then. But the apiVersion is different and how do we know what apiVersion a producer is using ? Our dashboards cannot have a-priori knowledge of the version numbers, and

Re: Kafka 2.1.0 JMX mbean broken ?

2018-12-14 Thread Raghav
Is this a test case for this commit: https://github.com/apache/kafka/pull/4506 ? I have tried using all possible cases but cannot get it to work. I cannot get it to work using mbean reader via JMX. Can any one please help? Or atleast confirm that it is broken. Thanks R On Fri, Dec 14, 2018 at

Re: Kafka 2.1.0 JMX mbean broken ?

2018-12-14 Thread Raghav
Thanks Ismael. How to query it in 2.1 ? I tried all possible ways including using version, but I am still getting the same exception message. Thanks for your help. On Thu, Dec 13, 2018 at 7:19 PM Ismael Juma wrote: > The metric was changed to include the API version. I believe this was in >

Re: Kafka 2.1.0 JMX mbean broken ?

2018-12-13 Thread Ismael Juma
The metric was changed to include the API version. I believe this was in the upgrade notes for 2.0.0. Ismael On Thu, Dec 13, 2018, 3:35 PM Raghav Hi > > We are trying to move from Kafka 1.1.0 to Kafka 2.1.0. We used to monitor > our 3 node Kafka using JMX. Upon moving to 2.1.0, we have observed

Kafka 2.1.0 JMX mbean broken ?

2018-12-13 Thread Raghav
Hi We are trying to move from Kafka 1.1.0 to Kafka 2.1.0. We used to monitor our 3 node Kafka using JMX. Upon moving to 2.1.0, we have observed that the *below* mentioned metric can't be retrie and we get the below exception: