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 <milindpar...@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.narkh...@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 <crypt...@gmail.com> wrote: >> Milind, if you are using t...
