On 9/8/15 6:58 PM, Jason Gustafson wrote:
> Hey Phil,
>
> You've stumbled onto one of the tricky aspects of the new consumer that
> we've been talking about recently. KafkaConsumer.subscribe() is
> asynchronous in the sense that it will return before partitions have been
> assigned. We could make i
Hey Phil,
You've stumbled onto one of the tricky aspects of the new consumer that
we've been talking about recently. KafkaConsumer.subscribe() is
asynchronous in the sense that it will return before partitions have been
assigned. We could make it synchronous, but we wouldn't be able to
guarantee h
I have been experimenting with the KafkaConsumer currently in
development [1]. Sorry if this should be a question for the user
list, but I am not sure if what I am seeing is something not working
yet or if I am misunderstanding the API. If I use
KafkaConsumer#subscribe to subscribe to a topic and
