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 <isma...@gmail.com> wrote: > 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 <raghavas...@gmail.com wrote: > > > 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: > > > > *"kafka.network:type=RequestMetrics,name=RequestsPerSec,request=Produce"* > > > > javax.management.InstanceNotFoundException: > > kafka.network:type=RequestMetrics,name=RequestsPerSec,request=Produce > > at > > > > > com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.getMBean(DefaultMBeanServerInterceptor.java:1095) > > at > > > > > com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.getMBeanInfo(DefaultMBeanServerInterceptor.java:1375) > > at > > > > > com.sun.jmx.mbeanserver.JmxMBeanServer.getMBeanInfo(JmxMBeanServer.java:920) > > at > > > > > javax.management.remote.rmi.RMIConnectionImpl.doOperation(RMIConnectionImpl.java:1462) > > at > > > > > javax.management.remote.rmi.RMIConnectionImpl.access$300(RMIConnectionImpl.java:76) > > at > > > > > javax.management.remote.rmi.RMIConnectionImpl$PrivilegedOperation.run(RMIConnectionImpl.java:1309) > > at > > > > > javax.management.remote.rmi.RMIConnectionImpl.doPrivilegedOperation(RMIConnectionImpl.java:1401) > > at > > > > > javax.management.remote.rmi.RMIConnectionImpl.getMBeanInfo(RMIConnectionImpl.java:905) > > at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) > > at > > > > > sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) > > at > > > > > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > > at java.lang.reflect.Method.invoke(Method.java:498) > > at sun.rmi.server.UnicastServerRef.dispatch(UnicastServerRef.java:324) > > at sun.rmi.transport.Transport$1.run(Transport.java:200) > > at sun.rmi.transport.Transport$1.run(Transport.java:197) > > at java.security.AccessController.doPrivileged(Native Method) > > at sun.rmi.transport.Transport.serviceCall(Transport.java:196) > > at > sun.rmi.transport.tcp.TCPTransport.handleMessages(TCPTransport.java:568) > > at > > > > > sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run0(TCPTransport.java:826) > > at > > > > > sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.lambda$run$0(TCPTransport.java:683) > > at java.security.AccessController.doPrivileged(Native Method) > > at > > > > > sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run(TCPTransport.java:682) > > at > > > > > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) > > at > > > > > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) > > at java.lang.Thread.run(Thread.java:745) > > at > > > > > sun.rmi.transport.StreamRemoteCall.exceptionReceivedFromServer(StreamRemoteCall.java:276) > > at > > sun.rmi.transport.StreamRemoteCall.executeCall(StreamRemoteCall.java:253) > > at sun.rmi.server.UnicastRef.invoke(UnicastRef.java:162) > > at com.sun.jmx.remote.internal.PRef.invoke(Unknown Source) > > at > javax.management.remote.rmi.RMIConnectionImpl_Stub.getMBeanInfo(Unknown > > Source) > > at > > > > > javax.management.remote.rmi.RMIConnector$RemoteMBeanServerConnection.getMBeanInfo(RMIConnector.java:1079) > > > > > > We even tried adding version to it, but no avail. > > > > Can someone please guide us how to > > get > "kafka.network:type=RequestMetrics,name=RequestsPerSec,request=Produce" > > value ? > > > > R > > > -- Raghav
