If broker A comes back, messages are routed back to A again. Ordering is guaranteed within a partition, not cross partitions.
Jun On Thu, May 10, 2012 at 6:28 PM, xiaoyu wang <xiaoyu.w...@gmail.com> wrote: > OK. I was wrong. Hmm, assume messages all goes to broker A and was routed > to broker B after A goes down.what happens when A comes back online? If I > have a consumer that consumes the topic, is ordering guaranteed? If so, how > does kafka guarantee ordering in this case? > > > > On Wed, May 9, 2012 at 6:17 PM, Jun Rao <jun...@gmail.com> wrote: > > > If you have a partitioner that always return 0, produce requests will > > always be routed to 1 broker. However, if that broker goes down, the > > requests will be routed to another broker. This is because the producer > > only route requests to live partitions. > > > > Jun > > > > On Wed, May 9, 2012 at 5:57 PM, xiaoyu wang <xiaoyu.w...@gmail.com> > wrote: > > > > > OK. I have the answer now. when I connect to brokers through zookeeper, > > the > > > record may go to any broker and the partitioner is for partition on the > > > broker. > > > > > > On Wed, May 9, 2012 at 5:48 PM, xiaoyu wang <xiaoyu.w...@gmail.com> > > wrote: > > > > > > > Thanks Jun. > > > > > > > > I think my question is if I have a program which produces a topic > with > > a > > > > partitioner that always returns 0, does all the messages go the same > > > > broker? If so, what happens if I restart the program, does the > messages > > > > still go the same broker? Note that all the connections are through > > > > zookeeper. > > > > > > > > > > > > Thanks, > > > > > > > > > > > > > > > > On Tue, May 8, 2012 at 5:37 PM, Jun Rao <jun...@gmail.com> wrote: > > > > > > > >> Xiaoyu, > > > >> > > > >> A simpler way to do that is to send all produce requests to 1 broker > > and > > > >> configure that broker to have 1 partition per topic. > > > >> > > > >> Jun > > > >> > > > >> On Tue, May 8, 2012 at 12:41 PM, xiaoyu wang <xiaoyu.w...@gmail.com > > > > > >> wrote: > > > >> > > > >> > Hello, > > > >> > > > > >> > I want to keep the order of record in my topic so I created the > > > producer > > > >> > with a partitioner that always returns 0. I have the following > > > questions > > > >> > > > > >> > > > > >> > - will my topic be stored in 1 broker only? > > > >> > - If so, which broker does my topic go to? > > > >> > - what happens if I change the partitioner later to e.g. random > > > >> > partitoner? > > > >> > > > > >> > > > > >> > Thanks, > > > >> > > > > >> > -Xiaoyu > > > >> > > > > >> > > > > > > > > > > > > > >
