Re: kafka.common.NotLeaderForPartitionException in Consumer

2015-06-22 Thread Srividhya Anantharamakrishnan
eeper > chroot option, so I think they would just form a single cluster. > > -Jason > > On Mon, Jun 22, 2015 at 3:50 PM, Srividhya Anantharamakrishnan < > srivid...@hedviginc.com> wrote: > > > Hi, > > > > I have the following Kafka Set up - Two 3-node c

kafka.common.NotLeaderForPartitionException in Consumer

2015-06-22 Thread Srividhya Anantharamakrishnan
Hi, I have the following Kafka Set up - Two 3-node clusters A, B, where each node is acting as a broker and is connected by on ZK running in one node in cluster A. I was able to publish messages from cluster A and could subscribe to consuming from both A and B clusters. However, I am suddenly ru

Re: NoSuchMethodError with Consumer Instantiation

2015-06-18 Thread Srividhya Anantharamakrishnan
Sorry for spamming, but any help would be greatly appreciated! On Thu, Jun 18, 2015 at 10:49 AM, Srividhya Anantharamakrishnan < srivid...@hedviginc.com> wrote: > The following are the jars in my classpath: > > 1. slf4j-log4j12-1.6.6.jar > 2. slf4j-api-1.6.6.jar > 3. zo

Re: NoSuchMethodError with Consumer Instantiation

2015-06-18 Thread Srividhya Anantharamakrishnan
something? On Wed, Jun 17, 2015 at 9:15 PM, Jaikiran Pai wrote: > You probably have the wrong version of the Kafka jar(s) within your > classpath. Which version of Kafka are you using and how have you setup the > classpath? > > -Jaikiran > > On Thursday 18 June 201

NoSuchMethodError with Consumer Instantiation

2015-06-17 Thread Srividhya Anantharamakrishnan
Hi, I am trying to set up Kafka in our cluster and I am running into the following error when Consumer is getting instantiated: java.lang.NoSuchMethodError: org.apache.kafka.common.utils.Utils.newThread(Ljava/lang/String;Ljava/lang/Runnable;Ljava/lang/Boolean;)Ljava/lang/Thread; at kafka