log, is there anything to indicate that the
> rebalance process on those hosts even started? Does this happen
> occasionally or every time you start the consumer group? Can you paste the
> output of ConsumerOffsetChecker and describe topic?
> >
> >Thanks,
> >Ad
___
>From: Dave Hamilton [dhamil...@nanigans.com]
>Sent: Wednesday, April 29, 2015 6:46 PM
>To: users@kafka.apache.org; users@kafka.apache.org
>Subject: Re: Unclaimed partitions
>
>Hi, would anyone be able to help me with this issue? Thanks.
>
>- Dave
>
e the output of
ConsumerOffsetChecker and describe topic?
Thanks,
Aditya
From: Dave Hamilton [dhamil...@nanigans.com]
Sent: Wednesday, April 29, 2015 6:46 PM
To: users@kafka.apache.org; users@kafka.apache.org
Subject: Re: Unclaimed partitions
Hi, would anyo
irming
>that you have partitions that are not being consumed from as opposed to
>consumer threads that aren't assigned any partitions.
>
>Aditya
>
>
>From: Dave Hamilton [dhamil...@nanigans.com]
>Sent: Tuesday, April 28, 2015 10:1
_
>From: Dave Hamilton [dhamil...@nanigans.com]
>Sent: Tuesday, April 28, 2015 10:19 AM
>To: users@kafka.apache.org
>Subject: Re: Unclaimed partitions
>
>I’m sorry, I forgot to specify that these processes are in the same consumer
>group.
>
&g
threads that aren't assigned any partitions.
Aditya
From: Dave Hamilton [dhamil...@nanigans.com]
Sent: Tuesday, April 28, 2015 10:19 AM
To: users@kafka.apache.org
Subject: Re: Unclaimed partitions
I’m sorry, I forgot to specify that these processes are i
you are assigning partitions in your application code. Did
>you mean to say that you are using the high level consumer API?
>
>Thanks,
>Aditya
>
>
>From: Dave Hamilton [dhamil...@nanigans.com]
>Sent: Tuesday, April 28, 2015 7:58 AM
&g
_
From: Dave Hamilton [dhamil...@nanigans.com]
Sent: Tuesday, April 28, 2015 7:58 AM
To: users@kafka.apache.org
Subject: Unclaimed partitions
Hi, I am trying to consume a 24-partition topic across 12 processes. Each
process is using the simple consumer API, and each is being assigned two
consum
Hi, I am trying to consume a 24-partition topic across 12 processes. Each
process is using the simple consumer API, and each is being assigned two
consumer threads. I have noticed when starting these processes that sometimes
some of my processes are not being assigned any partitions, and no reba
