Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka, mail # user - kafka 0.7.2 jmx issue


Copy link to this message
-
kafka 0.7.2 jmx issue
Said Elaissaoui 2013-03-01, 14:59
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