HI all;
Im using 0.8 consumer with kafka 0.10.0.1.
When i run my consumer app (within wildfly 10.0.x) Im getting follwoing
exception and consumer is not listning any messages;
I tried increasing *"rebalance.backoff.ms <http://rebalance.backoff.ms>",
"zookeeper.session.timeout.ms
<http://zookeeper.session.timeout.ms>","rebalance.max.retries" values,* but
still no luck.
If I write a simple java program with main method, it works for same topic
and groupID.

Can anyone point me the fix? (I could not update to latest version
(0.9.x)of consumer APIs

*Consumer.properties*

auto.commit.enable=true

rebalance.max.retries=4

auto.commit.interval.ms=101

zookeeper.connect=zk1.abc.com\:2181,zk2. abc.com\:2181,zk3.abc.com\:2181

auto.offset.reset=largest

rebalance.backoff.ms=10000

zookeeper.session.timeout.ms=6000

group.id=lob1

consumer.timeout.ms=-1

fetch.min.bytes=1


[1]

05:24:05,492 INFO  [stdout] (ServerService Thread Pool -- 75)
kafka.common.ConsumerRebalanceFailedException:
lob1_18bd15ac0c9c-1472621001050-5764721e can't rebalance after 4 retries

filerouter_1  | 05:24:05,492 INFO  [stdout] (ServerService Thread Pool --
75) at
kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.syncedRebalance(ZookeeperConsumerConnector.scala:670)
~[kafka_2.11-0.10.0.1.jar:?]

filerouter_1  | 05:24:05,492 INFO  [stdout] (ServerService Thread Pool --
75) at
kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$reinitializeConsumer(ZookeeperConsumerConnector.scala:977)
~[kafka_2.11-0.10.0.1.jar:?]

filerouter_1  | 05:24:05,493 INFO  [stdout] (ServerService Thread Pool --
75) at
kafka.consumer.ZookeeperConsumerConnector.consume(ZookeeperConsumerConnector.scala:264)
~[kafka_2.11-0.10.0.1.jar:?]

filerouter_1  | 05:24:05,493 INFO  [stdout] (ServerService Thread Pool --
75) at
kafka.javaapi.consumer.ZookeeperConsumerConnector.createMessageStreams(ZookeeperConsumerConnector.scala:85)
~[kafka_2.11-0.10.0.1.jar:?]

filerouter_1  | 05:24:05,494 INFO  [stdout] (ServerService Thread Pool --
75) at
kafka.javaapi.consumer.ZookeeperConsumerConnector.createMessageStreams(ZookeeperConsumerConnector.scala:97)
~[kafka_2.11-0.10.0.1.jar:?]

filerouter_1  | 05:24:05,494 INFO  [stdout] (ServerService Thread Pool --
75) at
com.abc.core.listener.KafkaMessageListener.start(KafkaMessageListener.java:126)
[core-0.0.1-SNAPSHOT.jar:?]

filerouter_1  | 05:24:05,494 INFO  [stdout] (ServerService Thread Pool --
75) at com.labc.bean.KafkaServiceBean.initialize(KafkaServiceBean.java:47)
[classes:?]

filerouter_1  | 05:24:05,494 INFO  [stdout] (ServerService Thread Pool --
75) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
~[?:1.8.0_91]

filerouter_1  | 05:24:05,495 INFO  [stdout] (ServerService Thread Pool --
75) at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
~[?:1.8.0_91]

filerouter_1  | 05:24:05,495 INFO  [stdout] (ServerService Thread Pool --
75) at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
~[?:1.8.0_91]

filerouter_1  | 05:24:05,495 INFO  [stdout] (ServerService Thread Pool --
75) at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_91]

filerouter_1  | 05:24:05,496 INFO  [stdout] (ServerService Thread Pool --
75) at
org.jboss.as.ee.component.ManagedReferenceLifecycleMethodInterceptor.processInvocation(ManagedReferenceLifecycleMethodInterceptor.java:96)
[wildfly-ee-10.1.0.Final.jar!/:10.1.0.Final]

filerouter_1  | 05:24:05,496 INFO  [stdout] (ServerService Thread Pool --
75) at
org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:340)
[jboss-invocation-1.4.1.Final.jar!/:1.4.1.Final]

filerouter_1  | 05:24:05,496 INFO  [stdout] (ServerService Thread Pool --
75) at
org.jboss.as.weld.ejb.Jsr299BindingsInterceptor.doLifecycleInterception(Jsr299BindingsInterceptor.java:114)
[wildfly-weld-10.1.0.Final.jar!/:10.1.0.Final]

filerouter_1  | 05:24:05,497 INFO  [stdout] (ServerService Thread Pool --
75) at
org.jboss.as.weld.ejb.Jsr299BindingsInterceptor.processInvocation(Jsr299BindingsInterceptor.java:103)
[wildfly-weld-10.1.0.Final.jar!/:10.1.0.Final]

filerouter_1  | 05:24:05,497 INFO  [stdout] (ServerService Thread Pool --
75) at
org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:340)
[jboss-invocation-1.4.1.Final.jar!/:1.4.1.Final]

filerouter_1  | 05:24:05,497 INFO  [stdout] (ServerService Thread Pool --
75) at
org.jboss.invocation.InterceptorContext$Invocation.proceed(InterceptorContext.java:437)
[jboss-invocation-1.4.1.Final.jar!/:1.4.1.Final]

filerouter_1  | 05:24:05,498 INFO  [stdout] (ServerService Thread Pool --
75) at
org.jboss.weld.ejb.AbstractEJBRequestScopeActivationInterceptor.aroundInvoke(AbstractEJBRequestScopeActivationInterceptor.java:73)
[weld-core-impl-2.3.5.Final.jar!/:2.3.5.Final]

filerouter_1  | 05:24:05,498 INFO  [stdout] (ServerService Thread Pool --
75) at
org.jboss.as.weld.ejb.EjbRequestScopeActivationInterceptor.processInvocation(EjbRequestScopeActivationInterceptor.java:83)
[wildfly-weld-10.1.0.Final.jar!/:10.1.0.Final]

filerouter_1  | 05:24:05,498 INFO  [stdout] (ServerService Thread Pool --
75) at
org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:340)
[jboss-invocation-1.4.1.Final.jar!/:1.4.1.Final]

filerouter_1  | 05:24:05,498 INFO  [stdout] (ServerService Thread Pool --
75) at
org.jboss.as.weld.injection.WeldInjectionInterceptor.processInvocation(WeldInjectionInterceptor.java:53)
[wildfly-weld-10.1.0.Final.jar!/:10.1.0.Final]

filerouter_1  | 05:24:05,499 INFO  [stdout] (ServerService Thread Pool --
75) at
org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:340)
[jboss-invocation-1.4.1.Final.jar!/:1.4.1.Final]

filerouter_1  | 05:24:05,499 INFO  [stdout] (ServerService Thread Pool --
75) at
org.jboss.as.ee.component.AroundConstructInterceptorFactory$1.processInvocation(AroundConstructInterceptorFactory.java:28)
[wildfly-ee-10.1.0.Final.jar!/:10.1.0.Final]

filerouter_1  | 05:24:05,499 INFO  [stdout] (ServerService Thread Pool --
75) at
org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:340)
[jboss-invocation-1.4.1.Final.jar!/:1.4.1.Final]

filerouter_1  | 05:24:05,499 INFO  [stdout] (ServerService Thread Pool --
75) at
org.jboss.as.weld.injection.WeldInterceptorInjectionInterceptor.processInvocation(WeldInterceptorInjectionInterceptor.java:56)
[wildfly-weld-10.1.0.Final.jar!/:10.1.0.Final]

filerouter_1  | 05:24:05,500 INFO  [stdout] (ServerService Thread Pool --
75) at
org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:340)
[jboss-invocation-1.4.1.Final.jar!/:1.4.1.Final]

filerouter_1  | 05:24:05,500 INFO  [stdout] (ServerService Thread Pool --
75) at
org.jboss.as.weld.ejb.Jsr299BindingsCreateInterceptor.processInvocation(Jsr299BindingsCreateInterceptor.java:100)
[wildfly-weld-10.1.0.Final.jar!/:10.1.0.Final]

filerouter_1  | 05:24:05,500 INFO  [stdout] (ServerService Thread Pool --
75) at
org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:340)
[jboss-invocation-1.4.1.Final.jar!/:1.4.1.Final]

filerouter_1  | 05:24:05,500 INFO  [stdout] (ServerService Thread Pool --
75) at
org.jboss.as.ee.component.NamespaceContextInterceptor.processInvocation(NamespaceContextInterceptor.java:50)
[wildfly-ee-10.1.0.Final.jar!/:10.1.0.Final]

filerouter_1  | 05:24:05,501 INFO  [stdout] (ServerService Thread Pool --
75) at
org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:340)
[jboss-invocation-1.4.1.Final.jar!/:1.4.1.Final]

filerouter_1  | 05:24:05,501 INFO  [stdout] (ServerService Thread Pool --
75) at
org.jboss.as.ejb3.tx.CMTTxInterceptor.invokeInOurTx(CMTTxInterceptor.java:275)
[wildfly-ejb3-10.1.0.Final.jar!/:10.1.0.Final]

filerouter_1  | 05:24:05,501 INFO  [stdout] (ServerService Thread Pool --
75) at
org.jboss.as.ejb3.tx.CMTTxInterceptor.requiresNew(CMTTxInterceptor.java:349)
[wildfly-ejb3-10.1.0.Final.jar!/:10.1.0.Final]

filerouter_1  | 05:24:05,501 INFO  [stdout] (ServerService Thread Pool --
75) at
org.jboss.as.ejb3.tx.LifecycleCMTTxInterceptor.processInvocation(LifecycleCMTTxInterceptor.java:68)
[wildfly-ejb3-10.1.0.Final.jar!/:10.1.0.Final]

filerouter_1  | 05:24:05,501 INFO  [stdout] (ServerService Thread Pool --
75) at
org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:340)
[jboss-invocation-1.4.1.Final.jar!/:1.4.1.Final]

filerouter_1  | 05:24:05,502 INFO  [stdout] (ServerService Thread Pool --
75) at
org.jboss.as.weld.injection.WeldInjectionContextInterceptor.processInvocation(WeldInjectionContextInterceptor.java:43)
[wildfly-weld-10.1.0.Final.jar!/:10.1.0.Final]

filerouter_1  | 05:24:05,502 INFO  [stdout] (ServerService Thread Pool --
75) at
org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:340)
[jboss-invocation-1.4.1.Final.jar!/:1.4.1.Final]

filerouter_1  | 05:24:05,502 INFO  [stdout] (ServerService Thread Pool --
75) at
org.jboss.as.ejb3.component.interceptors.CurrentInvocationContextInterceptor.processInvocation(CurrentInvocationContextInterceptor.java:41)
[wildfly-ejb3-10.1.0.Final.jar!/:10.1.0.Final]

filerouter_1  | 05:24:05,502 INFO  [stdout] (ServerService Thread Pool --
75) at
org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:340)
[jboss-invocation-1.4.1.Final.jar!/:1.4.1.Final]

filerouter_1  | 05:24:05,502 INFO  [stdout] (ServerService Thread Pool --
75) at
org.jboss.as.ee.concurrent.ConcurrentContextInterceptor.processInvocation(ConcurrentContextInterceptor.java:45)
[wildfly-ee-10.1.0.Final.jar!/:10.1.0.Final]

filerouter_1  | 05:24:05,503 INFO  [s
-- 
-Ratha
http://vvratha.blogspot.com/

Reply via email to