Re: Consistency and Availability on Node Failures

2014-10-16 Thread gshapira
It may be a minority, I can't tell yet. But in some apps we need to know that a consumer, who is assigned a single partition, will get all data about a subset of users. This is way more flexible than multiple topics since we still have the benefits of partition reassignment, load balancing bet

Re: read N items from topic

2014-10-16 Thread gshapira
Using the high level consumer, each consumer in the group can call iter.next () in a loop until they get the number of messages you need. — Sent from Mailbox On Thu, Oct 16, 2014 at 10:18 AM, Josh J wrote: > hi, > How do I read N items from a topic? I also would like to do this for a > consume

Re: Topic doesn't exist exception

2014-10-17 Thread gshapira
Its using the sync producer without waiting for any broker to acknowledge the write. This explains the lack of errors you are seeing. — Sent from Mailbox On Fri, Oct 17, 2014 at 3:15 PM, Mohit Anchlia wrote: > Little confused :) From one of the examples I am using property > request.required.