Hi Kevin, At the moment, the timeout parameter in poll() really only applies when the consumer has an active partition assignment. In particular, it will block indefinitely to get that assignment. If there are no brokers to connect to or if you accidentally point it to an 0.8 cluster, it will probably block forever. This is most likely what is happening in your test case. This is 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, Dec 10, 2015 at 11:50 AM, Kevin Carr <kscar...@gmail.com> wrote: > 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. >
