Kafka guarantees FIFO per partition. If a node goes down, clients can't write/read to partitions on that node. So, data on those partitions are delayed. Once the broker is up, data will be delivered in order.
In 0.8, availability will be improved with intra-cluster replication. Thanks, Jun On Mon, Oct 22, 2012 at 8:45 AM, howard chen <howac...@gmail.com> wrote: > Hi, > > On Mon, Oct 22, 2012 at 5:58 AM, Jun Rao <jun...@gmail.com> wrote: > > Howard, > > > > In 0.7, partitions are local to each broker. So, if you set # partitions > to > > 3 per broker, you will get a total of 9 partitions with 3 brokers. Also, > > since there is no redundancy across brokers, if a broker goes down, none > of > > all partitions on the broker is available. So num_partitions will shrink. > > > > When people use queue, it must support FIFO semantic, so considering > the "partitions", if any node goes down, the whole queue is basically > useless then? > > THanks. >
