Re: Common Identity between brokers
This might be useful reading as it outlines why Cluster ID was added and lists a few ways that clusters can be identifies prior to that feature enhancement. https://cwiki.apache.org/confluence/display/KAFKA/KIP-78%3A+Cluster+Id <https://cwiki.apache.org/confluence/display/KAFKA/KIP-78:+Cluster+Id> -hans > On Mar 14, 2017, at 11:20 AM, Sumit Maheshwari wrote: > > Can anyone answer the above query? > > On Mon, Mar 13, 2017 at 3:41 PM, Sumit Maheshwari > wrote: > >> Hi, >> >> How can we identify if a set of brokers (nodes) belong to same cluster? >> I understand we can use the zookeeper where all the brokers pointing to >> same zookeeper URL's belong to same cluster. >> But is there a common identity between brokers which can help identify if >> brokers belong to same cluster? >> >> I have seen in recent Kafka release there is concept of clusterId but that >> is available from 0.10.1.0. I am using little older version of Kafka. >> >> Thanks, >> Sumit >>
Re: Common Identity between brokers
Can anyone answer the above query? On Mon, Mar 13, 2017 at 3:41 PM, Sumit Maheshwari wrote: > Hi, > > How can we identify if a set of brokers (nodes) belong to same cluster? > I understand we can use the zookeeper where all the brokers pointing to > same zookeeper URL's belong to same cluster. > But is there a common identity between brokers which can help identify if > brokers belong to same cluster? > > I have seen in recent Kafka release there is concept of clusterId but that > is available from 0.10.1.0. I am using little older version of Kafka. > > Thanks, > Sumit >
Common Identity between brokers
Hi, How can we identify if a set of brokers (nodes) belong to same cluster? I understand we can use the zookeeper where all the brokers pointing to same zookeeper URL's belong to same cluster. But is there a common identity between brokers which can help identify if brokers belong to same cluster? I have seen in recent Kafka release there is concept of clusterId but that is available from 0.10.1.0. I am using little older version of Kafka. Thanks, Sumit
