org.thales.punch.platform.api

Interface IKafkaCluster

All Known Implementing Classes:

KafkaClusterImpl

public interface IKafkaCluster

Interface used to access settings from the platform relative to kafka clusters.

Author:

cedric

Method Summary

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.

Method Detail

getName

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. It is the name of the kafka cluster section in the punchplatform.properties file.

Returns:

the name of the kafka cluster

getZkConnectionString

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)

Returns:

the associated zookeeper connection string

getZkRoot

String getZkRoot()

Returns:

the associated zookeeper root id

getZookeeperCluster

IZookeeperCluster getZookeeperCluster()

Each Kafka cluster is associated to a zookeeper cluster.

Returns:

the associated zookeeper cluster

getBrokerNames

Map<Integer,String> getBrokerNames()

Get a list of this cluster servers/brokers.

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.

Returns:

the set of servers as a map id url