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

Reply via email to