kafka 0.7.2 jmx issue

[Said Elaissaoui]

Hi all,

I'm trying to integrate kafka producer to weblogic 11 server using jdk1.6, 
and i saw in some errors in the logs:

javax.management.NotCompliantMBeanException: MBean class 
kafka.producer.async.AsyncProducerStats does not implement DynamicMBean, 
neither follows the Standard MBean conventions 
(javax.management.NotCompliantMBeanException: Class 
kafka.producer.async.AsyncProducerStats is not a JMX compliant Standard 
MBean) nor the MXBean conventions 
(javax.management.NotCompliantMBeanException: 
kafka.producer.async.AsyncProducerStats: Class 
kafka.producer.async.AsyncProducerStats is not a JMX compliant MXBean)
        at 
com.sun.jmx.mbeanserver.Introspector.checkCompliance(Introspector.java:160)
        at 
com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:305)
        at 
com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:482)
        at 
weblogic.management.jmx.mbeanserver.WLSMBeanServerInterceptorBase$27.run(WLSMBeanServerInterceptorBase.java:714)
        at java.security.AccessController.doPrivileged(Native Method)
        at 
weblogic.management.jmx.mbeanserver.WLSMBeanServerInterceptorBase.registerMBean(WLSMBeanServerInterceptorBase.java:709)
        at 
weblogic.management.mbeanservers.internal.JMXContextInterceptor.registerMBean(JMXContextInterceptor.java:445)
        at 
weblogic.management.jmx.mbeanserver.WLSMBeanServerInterceptorBase$27.run(WLSMBeanServerInterceptorBase.java:712)
        at java.security.AccessController.doPrivileged(Native Method)
        at 
weblogic.management.jmx.mbeanserver.WLSMBeanServerInterceptorBase.registerMBean(WLSMBeanServerInterceptorBase.java:709)
        at 
weblogic.management.jmx.mbeanserver.WLSMBeanServer.registerMBean(WLSMBeanServer.java:462)
        at kafka.utils.Utils$.registerMBean(Utils.scala:421)
        at 
kafka.producer.async.AsyncProducerStats$.<init>(AsyncProducerStats.scala:45)
        at 
kafka.producer.async.AsyncProducerStats$.<clinit>(AsyncProducerStats.scala)
        at kafka.producer.async.AsyncProducer.send(AsyncProducer.scala:73)
        at 
kafka.producer.ProducerPool$$anonfun$send$1$$anonfun$apply$mcVI$sp$5$$anonfun$apply$2.apply(ProducerPool.scala:129)
        at scala.collection.immutable.List.foreach(List.scala:45)
        at 
kafka.producer.ProducerPool$$anonfun$send$1$$anonfun$apply$mcVI$sp$5.apply(ProducerPool.scala:128)



I had a look the MBean and it seems ok for me.

Any help ?

Thanks,

Said