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
-
Re: kafka 0.7.2 jmx issue
Jun Rao 2013-03-01, 18:05
Hmm, not sure what the problem is. At LinkedIn, our producers typically run
in a Tomcat or Jetty container and they seem to work.

Thanks,

Jun

On Fri, Mar 1, 2013 at 6:58 AM, Said Elaissaoui <[EMAIL PROTECTED]
> wrote:

> 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
>
>
>