I have created a local kafka with local zookeeper, and testing with this
setup, I am able to poll properly. So it is something to do with my setup.
On Thu, Dec 10, 2015 at 2:45 PM Jason Gustafson wrote:
> You just have to set "group.id" in the configuration. Please also include
> the version of
You just have to set "group.id" in the configuration. Please also include
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 J
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 Gustafson wrote:
> And just to be clear, the broker is on 0.9? Perhaps you can enable debug
> logging and send a snippet?
>
> -Jason
>
> On Thu, Dec 10, 2015 at 12:2
And just to be clear, the broker is on 0.9? Perhaps you can enable debug
logging and send a snippet?
-Jason
On 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
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 Kevin,
>
> At the moment, the timeout parameter in poll() really only applies when the
> consumer has an active partition ass
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 prob
