Re: Kafka 0.8's VerifyConsumerRebalance reports an error

2014-06-26 Thread Neha Narkhede
This is a bug in the tool. Please file a bug and attach these error/info logs to it. Thanks, Neha On Thu, Jun 26, 2014 at 5:24 AM, Yury Ruchin wrote: > I have set log level to DEBUG and saw something strange in the output. For > each topic partition, I see the following pattern: > > [2014-06-2

Re: Kafka 0.8's VerifyConsumerRebalance reports an error

2014-06-26 Thread Yury Ruchin
I have set log level to DEBUG and saw something strange in the output. For each topic partition, I see the following pattern: [2014-06-26 16:00:24,467] ERROR No owner for partition [,0] (kafka.tools.VerifyConsumerRebalance$) ... [2014-06-26 16:00:24,469] INFO Owner of partition [,0] is _-1403049

Re: Kafka 0.8's VerifyConsumerRebalance reports an error

2014-06-24 Thread Neha Narkhede
I would turn on DEBUG on the tool to see which url it reads and doesn't find the owners. On Tue, Jun 24, 2014 at 11:28 AM, Yury Ruchin wrote: > I've just double-checked. The URL is correct, the same one is used by Kafka > clients. > > > 2014-06-24 22:21 GMT+04:00 Neha Narkhede : > > > Is it p

Re: Kafka 0.8's VerifyConsumerRebalance reports an error

2014-06-24 Thread Yury Ruchin
I've just double-checked. The URL is correct, the same one is used by Kafka clients. 2014-06-24 22:21 GMT+04:00 Neha Narkhede : > Is it possible that maybe the zookeeper url used for the > VerifyConsumerRebalance tool is incorrect? > > > On Tue, Jun 24, 2014 at 12:02 AM, Yury Ruchin > wrote: >

Re: Kafka 0.8's VerifyConsumerRebalance reports an error

2014-06-24 Thread Neha Narkhede
Is it possible that maybe the zookeeper url used for the VerifyConsumerRebalance tool is incorrect? On Tue, Jun 24, 2014 at 12:02 AM, Yury Ruchin wrote: > Hi, > > I've run into the following problem. I try to read from a 50-partition > Kafka topic using high level consumer with 8 streams. I'm u

Kafka 0.8's VerifyConsumerRebalance reports an error

2014-06-24 Thread Yury Ruchin
Hi, I've run into the following problem. I try to read from a 50-partition Kafka topic using high level consumer with 8 streams. I'm using 8-thread pool, each thread handling one stream. After a short time, the threads reading from the stream stop reading. Lag between topic latest offset and the c