Did you set the replication factor to be more than 1? Thanks,
Jun On Sat, Oct 18, 2014 at 2:32 AM, Yu Yang <yuyan...@gmail.com> wrote: > Hi all, > > We have a kafka 0.8.1 cluster. We implemented a consumers for the topics on > the Kafka 0.8 cluster using high-level consumer api. We observed that if > the Kafka cluster was down and got rebooted and the consumer was running, > the consumer will fail to read a few topic partitions due to negative lag > behind value. How shall we handle disaster recovery without re-reading the > processed messages? > > Thanks! > > -Yu >
