org.thales.punch.platform.impl

Class KafkaClusterImpl

java.lang.Object

java.util.AbstractMap<K,V>

java.util.HashMap<String,Object>

org.thales.punch.settings.impl.SettingsMapImpl

org.thales.punch.settings.impl.NamedSettingsMapImpl

org.thales.punch.settings.impl.JsonSettingsMapImpl

org.thales.punch.platform.impl.KafkaClusterImpl

All Implemented Interfaces:

Serializable, Cloneable, Map<String,Object>, IKafkaCluster, ISettingsMap

public class KafkaClusterImpl
extends JsonSettingsMapImpl
implements IKafkaCluster

Implementation of IKafkaCLuster.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class java.util.AbstractMap

AbstractMap.SimpleEntry<K,V>, AbstractMap.SimpleImmutableEntry<K,V>

Nested classes/interfaces inherited from interface java.util.Map

Map.Entry<K,V>

Field Summary

Fields inherited from class org.thales.punch.settings.impl.SettingsMapImpl

originatorName

Constructor Summary

Constructors

Constructor and Description
KafkaClusterImpl(String clusterName, IPunchPlatformProperties properties)

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.

Methods inherited from class org.thales.punch.settings.impl.NamedSettingsMapImpl

newSettingsListChild, newSettingsMapChild, put, putAll, putWithNoCloning, setOriginatorName

Methods inherited from class org.thales.punch.settings.impl.SettingsMapImpl

asFlatValuesMap, asFlatValuesMap, asFlatValuesMapIgnoreSettingsList, asHjsonString, asJsonString, asJsonString, asKvString, asListFlatValuesMapIgnoreSettingsList, asYamlString, childAsJson, childAsRawContent, childAsTarGz, childFileAsMap, childIsDir, childIsFile, getAsBoolean, getAsBoolean, getAsDouble, getAsInteger, getAsInteger, getAsIsoDateTime, getAsLong, getAsLong, getAsMsDuration, getAsRequiredBoolean, getAsRequiredDouble, getAsRequiredInteger, getAsRequiredIsoDateTime, getAsRequiredLong, getAsRequiredObject, getAsRequiredObjectOfClass, getAsRequiredSettingsList, getAsRequiredSettingsMap, getAsRequiredString, getAsRequiredTimeValue, getAsRequiredZonedDateTime, getAsSettingsList, getAsSettingsList, getAsSettingsListOrEmpty, getAsSettingsMap, getAsSettingsMap, getAsString, getAsString, getAsTimeValue, getChildName, getCreateMap, getDeepCopy, getMapOrEmpty, getNestedProperty, getNewInstance, getOrCreateNestedSettingsMap, getOriginatorName, getRequiredNestedProperty, getStringOrFail, getStringOrFail, getTimeValueMs, newSettingsMapChild, overrideWith, putUsingDottedPath, putUsingSlashPath, removeUsingDottedPath, removeUsingSlashPath, setJsonDecoding, setNestedProperty, setPropertyIfMissing

Methods inherited from class java.util.HashMap

clear, clone, compute, computeIfAbsent, computeIfPresent, containsKey, containsValue, entrySet, forEach, get, getOrDefault, isEmpty, keySet, merge, putIfAbsent, remove, remove, replace, replace, replaceAll, size, values

Methods inherited from class java.util.AbstractMap

equals, hashCode, toString

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.thales.punch.settings.api.ISettingsMap

childAsListOfString, childAsMapEntries, childAsMapValues, childAsRequiredListOfString, childAsRequiredString, childAsString, childAsStringContent, getCreateAsListOfMap

Methods inherited from interface java.util.Map

clear, compute, computeIfAbsent, computeIfPresent, containsKey, containsValue, entrySet, equals, forEach, get, getOrDefault, hashCode, isEmpty, keySet, merge, putIfAbsent, remove, remove, replace, replace, replaceAll, size, values

Constructor Detail

KafkaClusterImpl

public KafkaClusterImpl(String clusterName,
                        IPunchPlatformProperties properties)

Parameters:

clusterName - a kafka cluster name

properties - the platform properties

Method Detail

getName

public String getName()

Description copied from interface: IKafkaCluster

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.

Specified by:

getName in interface IKafkaCluster

Returns:

the name of the kafka cluster

getZkConnectionString

public String getZkConnectionString()

Description copied from interface: IKafkaCluster

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)

Specified by:

getZkConnectionString in interface IKafkaCluster

Returns:

the associated zookeeper connection string

getZkRoot

public String getZkRoot()

Specified by:

getZkRoot in interface IKafkaCluster

Returns:

the associated zookeeper root id

getZookeeperCluster

public IZookeeperCluster getZookeeperCluster()

Description copied from interface: IKafkaCluster

Each Kafka cluster is associated to a zookeeper cluster.

Specified by:

getZookeeperCluster in interface IKafkaCluster

Returns:

the associated zookeeper cluster

getBrokerNames

public Map<Integer,String> getBrokerNames()

Description copied from interface: IKafkaCluster

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.

Specified by:

getBrokerNames in interface IKafkaCluster

Returns:

the set of servers as a map id url