I am configuring the way it says in the api doc.
Topic is 1 partition
I set the group.id, and subscribe to the topic.
If I call poll(100) the function never returns. I have to stop the unit
test, because it never stops. I have waited for up to 10 minutes.
Any Ideas?
Thanks for your help.
a
> known issue, but surprisingly difficult to handle in a reasonable way due
> to the fact that the consumer is single-threaded. We are working on this
> problem, but for now, the best solution is to use wakeup() to break from
> the poll() from an external thread.
>
> -Jason
>
> On Thu
Thu, Dec 10, 2015 at 12:22 PM, Kevin Carr wrote:
>
> > In this case I have just published the message via a producer and
> > connecting to the same broker list to consume.
> >
> > On Thu, Dec 10, 2015, 2:18 PM Jason Gustafson
> wrote:
> >
> > > Hi Kevi
> the version of the broker.
>
> -Jason
>
> On Thu, Dec 10, 2015 at 12:38 PM, Kevin Carr wrote:
>
> > Sounds like a plan. I will see about getting that.
> >
> > I don't have to register a group id do I?
> >
> > On Thu, Dec 10, 2015, 2:37 PM Jason
I am using the new Subscriber API and I poll. The poll returns 2005
messages. I process 2 of them, and then set the offset to the 2nd message
offset that I processed.
I then call commitSync with the TopicPartition and this new offset. When I
list the group with the command line tool, it always
ere?
>
> Guozhang
>
> On Thu, Dec 10, 2015 at 2:45 PM, Kevin Carr wrote:
>
> > I am using the new Subscriber API and I poll. The poll returns 2005
> > messages. I process 2 of them, and then set the offset to the 2nd
> message
> > offset that I processed.
