kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Neha Narkhede <neha.narkh...@gmail.com>
Subject Re: ways to exit the blocking iterator
Date Wed, 29 Feb 2012 18:34:44 GMT
Milind,

Those semantics will be possible after
https://issues.apache.org/jira/browse/KAFKA-264 is resolved.
It is still in proposal phase, please let us know if you have comments
on the design.

Thanks,
Neha

On Tue, Feb 28, 2012 at 7:37 PM, Milind Parikh <milindparikh@gmail.com> wrote:
> Neha
> Thanks. I am looking for the semantics of ensuring that ALL consumers would
> somehow unblock. This is probably not doable with the queue semantics.
>
> /***********************
> sent from my android...please pardon occasional typos as I respond @ the
> speed of thought
> ************************/
>
> On Feb 28, 2012 12:44 PM, "Neha Narkhede" <neha.narkhede@gmail.com> wrote:
>
>>> should ideally deliver a unblock message to the iterator and then
> continue
> delivering the messag...
> I'm not sure what you mean by this. What will happen, in your example,
> is that the consumer iterator will get messages 1 and 2 only.
> If you have multiple instances of the zookeeper consumer, they will
> get messages 3 and 4. If you don't, then you will get 3 and 4, the
> next time you start the consumer connector again.
>
> Thanks,
> Neha
>
>
> On Tue, Feb 28, 2012 at 6:08 AM, Joe Stein <cryptcom@gmail.com> wrote:
>> Milind, if you are using t...

Mime
View raw message