Hi,

My name is Deepak and I work for salesforce. We are using kafka 8.11  and
have a question about starting kafka with same broker id.

Steps:

Start a kakfa broker with broker id =1 -> it starts fine with external ZK
Start another kafka with same broker id =1 .. it does not start the kafka
which is expected but I am seeing the following log and it keeps retrying
forever.

Is there way to control how many time a broker tries to starts itself with
the same broker id ?


Thanks
Deepak

[2015-02-18 14:47:20,713] INFO conflict in /controller data:
{"version":1,"brokerid":19471,"timestamp":"1424299100135"} stored data:
{"version":1,"brokerid":19471,"timestamp":"1424288444314"}
(kafka.utils.ZkUtils$)

[2015-02-18 14:47:20,716] INFO I wrote this conflicted ephemeral node
[{"version":1,"brokerid":19471,"timestamp":"1424299100135"}] at /controller
a while back in a different session, hence I will backoff for this node to
be deleted by Zookeeper and retry (kafka.utils.ZkUtils$)

[2015-02-18 14:47:30,719] INFO conflict in /controller data:
{"version":1,"brokerid":19471,"timestamp":"1424299100135"} stored data:
{"version":1,"brokerid":19471,"timestamp":"1424288444314"}
(kafka.utils.ZkUtils$)

[2015-02-18 14:47:30,722] INFO I wrote this conflicted ephemeral node
[{"version":1,"brokerid":19471,"timestamp":"1424299100135"}] at /controller
a while back in a different session, hence I will backoff for this node to
be deleted by Zookeeper and retry (kafka.utils.ZkUtils$)

Reply via email to