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
I’m sorry, I forgot to specify that these processes are in the same consumer
group.
Thanks,
Dave
On 4/28/15, 1:15 PM, "Aditya Auradkar" wrote:
>Hi Dave,
>
>The simple consumer doesn't do any state management across consumer instances.
>So I'm not sure how you are assigning partitions in y
Hi Dave,
The simple consumer doesn't do any state management across consumer instances.
So I'm not sure how 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: D
