public class TopicImpl extends JsonSettingsMapImpl implements ITopic
IApplication implementationAbstractMap.SimpleEntry<K,V>, AbstractMap.SimpleImmutableEntry<K,V>originatorName| Constructor and Description |
|---|
TopicImpl(IEntity entity,
Map<String,Object> map,
String name) |
TopicImpl(String cluster,
String topic,
Integer partition,
Integer replicationFactor,
String retentionBytes,
String deleteRetention,
String cleanupPolicy) |
| Modifier and Type | Method and Description |
|---|---|
Object |
getAsRequiredObjectOfClass(String key,
Class<? extends Object> expectedClass) |
IEntity |
getChannel() |
Map<String,String> |
getConfigs()
This return, if defined, the "delete.retention.ms", "retention.bytes" and "cleanup.policy"
|
String |
getKafkaCluster() |
String |
getName() |
int |
getPartitionNumber() |
int |
getReplicationFactor() |
newSettingsListChild, newSettingsMapChild, put, putAll, putWithNoCloning, setOriginatorNameasFlatValuesMap, 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, 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, setPropertyIfMissingclear, clone, compute, computeIfAbsent, computeIfPresent, containsKey, containsValue, entrySet, forEach, get, getOrDefault, isEmpty, keySet, merge, putIfAbsent, remove, remove, replace, replace, replaceAll, size, valuesequals, hashCode, toStringfinalize, getClass, notify, notifyAll, wait, wait, waitasFlatValuesMap, asFlatValuesMap, asFlatValuesMapIgnoreSettingsList, asHjsonString, asJsonString, asJsonString, asKvString, asListFlatValuesMapIgnoreSettingsList, asYamlString, childAsJson, childAsListOfString, childAsMapEntries, childAsMapValues, childAsRawContent, childAsRequiredListOfString, childAsRequiredString, childAsString, childAsStringContent, childAsTarGz, childFileAsMap, childIsDir, childIsFile, getAsBoolean, getAsBoolean, getAsDouble, getAsInteger, getAsInteger, getAsIsoDateTime, getAsLong, getAsLong, getAsMsDuration, getAsRequiredBoolean, getAsRequiredDouble, getAsRequiredInteger, getAsRequiredIsoDateTime, getAsRequiredLong, getAsRequiredObject, getAsRequiredSettingsList, getAsRequiredSettingsMap, getAsRequiredString, getAsRequiredTimeValue, getAsRequiredZonedDateTime, getAsSettingsList, getAsSettingsList, getAsSettingsListOrEmpty, getAsSettingsMap, getAsSettingsMap, getAsString, getAsString, getAsTimeValue, getCreateAsListOfMap, getCreateMap, getDeepCopy, getMapOrEmpty, getNestedProperty, getOrCreateNestedSettingsMap, getOriginatorName, getRequiredNestedProperty, getStringOrFail, getStringOrFail, getTimeValueMs, overrideWith, putUsingDottedPath, putUsingSlashPath, removeUsingDottedPath, removeUsingSlashPath, setNestedProperty, setOriginatorName, setPropertyIfMissingclear, compute, computeIfAbsent, computeIfPresent, containsKey, containsValue, entrySet, equals, forEach, get, getOrDefault, hashCode, isEmpty, keySet, merge, put, putAll, putIfAbsent, remove, remove, replace, replace, replaceAll, size, valuespublic TopicImpl(IEntity entity, Map<String,Object> map, String name)
entity - channelmap - mapname - namepublic IEntity getChannel()
getChannel in interface ITopicpublic String getName()
public String getKafkaCluster() throws ConfigurationException
getKafkaCluster in interface ITopicConfigurationExceptionpublic int getPartitionNumber()
getPartitionNumber in interface ITopicpublic int getReplicationFactor()
getReplicationFactor in interface ITopicpublic Map<String,String> getConfigs()
ITopicgetConfigs in interface ITopicpublic Object getAsRequiredObjectOfClass(String key, Class<? extends Object> expectedClass)
getAsRequiredObjectOfClass in interface ISettingsMapgetAsRequiredObjectOfClass in class SettingsMapImplkey - the property key to retrieveexpectedClass - the class of which the property must be checked an instance ofCopyright © 2014–2022. All rights reserved.