This is from the broker 3's log: [2013-08-22 15:40:02,984] WARN [KafkaApi-3] Fetch request: Partition [tes t.replica1.default,0] doesn't exist on 3 (kafka.server.KafkaApis)
Here is what list topic command shows: topic: test.replica1.default partition: 0 leader: 3 replicas: 3 isr: 3 topic: test.replica1.default partition: 1 leader: 1 replicas: 1 isr: 1 topic: test.replica1.default partition: 2 leader: 2 replicas: 2 isr: 2 Any idea on where the warning is from? Regards, Libo