public interface IKafkaCluster
Modifier and Type | Method and Description |
---|---|
Map<Integer,String> |
getBrokerNames()
Get a list of this cluster servers/brokers.
|
String |
getName()
The logical name of the cluster, used to reference it in the Channels configuration files
and to identify it to the user in log strings.
|
String |
getZkConnectionString()
The Zookeeper connection string, including all node:port (comma separated) and the additional
root node of the Kafka cluster (as configured in the cluster brokers configuration file)
|
String |
getZkRoot() |
IZookeeperCluster |
getZookeeperCluster()
Each Kafka cluster is associated to a zookeeper cluster.
|
String getName()
String getZkConnectionString()
String getZkRoot()
IZookeeperCluster getZookeeperCluster()
Map<Integer,String> getBrokerNames()
Watchout up to craig 5.2.1 we only have a list of broker urls without their ids. We make the id start with 1 to conform to production deployment(s).
We now set specifically the broker ids in the punchplatform.properties.
Copyright © 2014–2023. All rights reserved.