Package org.mases.datadistributionmanager.configuration

Class KafkaConfiguration

java.lang.Object

org.mases.datadistributionmanager.BaseConfiguration

org.mases.datadistributionmanager.GlobalConfiguration

org.mases.datadistributionmanager.CommonConfiguration

org.mases.datadistributionmanager.configuration.KafkaConfiguration

All Implemented Interfaces:

IConfiguration

Direct Known Subclasses:

KafkaChannelConfiguration

public class KafkaConfiguration
extends CommonConfiguration

The configuration class for Kafka

Field Summary

Fields inherited from class org.mases.datadistributionmanager.CommonConfiguration

ChannelSeekTimeoutKey, CommitSyncKey, CommitTimeoutKey, ConsumerTimeoutKey, CreateChannelTimeoutKey, EventSyncKey, InitialOffsetKey, KeepAliveTimeoutKey, ProducerTimeoutKey, ReceiveTimeoutKey

Fields inherited from class org.mases.datadistributionmanager.GlobalConfiguration

GlobalLogLevelKey, MastershipLibraryKey, MaxMessageSizeKey, ProtocolKey, ProtocolLibraryKey, ServerLostTimeoutKey

Constructor Summary

Constructors

Constructor	Description
KafkaConfiguration()	Initialize a new instance of KafkaConfiguration
KafkaConfiguration(IConfiguration originalConf)	Duplicates a configuration

Method Summary

Methods inherited from class org.mases.datadistributionmanager.CommonConfiguration

getChannelSeekTimeout, getCommitSync, getCommitTimeout, getConsumerTimeout, getCreateChannelTimeout, getEventSync, getInitialOffset, getKeepAliveTimeout, getProducerTimeout, getReceiveTimeout, setChannelSeekTimeout, setCommitSync, setCommitTimeout, setConsumerTimeout, setCreateChannelTimeout, setEventSync, setInitialOffset, setKeepAliveTimeout, setProducerTimeout, setReceiveTimeout

Methods inherited from class org.mases.datadistributionmanager.GlobalConfiguration

getGlobalLogLevel, getMastershipLibrary, getMaxMessageSize, getProtocol, getProtocolLibrary, getServerLostTimeout, setGlobalLogLevel, setMastershipLibrary, setMaxMessageSize, setProtocol, setProtocolLibrary, setServerLostTimeout

Methods inherited from class org.mases.datadistributionmanager.BaseConfiguration

getConfiguration

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KafkaConfiguration

public KafkaConfiguration()

Initialize a new instance of KafkaConfiguration

KafkaConfiguration

public KafkaConfiguration(IConfiguration originalConf)

Duplicates a configuration

Parameters:

originalConf - IConfiguration to duplicate