Package org.mases.datadistributionmanager.configuration

Class KafkaChannelConfiguration

java.lang.Object

org.mases.datadistributionmanager.BaseConfiguration

org.mases.datadistributionmanager.GlobalConfiguration

org.mases.datadistributionmanager.CommonConfiguration

org.mases.datadistributionmanager.configuration.KafkaConfiguration

org.mases.datadistributionmanager.configuration.KafkaChannelConfiguration

All Implemented Interfaces:

IConfiguration

public class KafkaChannelConfiguration
extends KafkaConfiguration

The configuration class for Kafka channel

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	KafkaChannelConfiguration.InitialOffsetTypes	Specific values to use within CommonConfiguration.setInitialOffset(Long) when channel is based on Kafka
static class	KafkaChannelConfiguration.KafkaConfigurationType	Kafka configuration type

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	AllowAutoCreateTopicsKey	See .NET AllowAutoCreateTopicsKey
static java.lang.String	ApiVersionFallbackKey	See .NET ApiVersionFallbackKey
static java.lang.String	ApiVersionRequestKey	See .NET ApiVersionRequestKey
static java.lang.String	ApiVersionRequestTimeoutKey	See .NET ApiVersionRequestTimeoutKey
static java.lang.String	AutoCommitIntervalKey	See .NET AutoCommitIntervalKey
static java.lang.String	AutoOffsetResetKey	See .NET AutoOffsetResetKey
static java.lang.String	BatchNumMessagesKey	See .NET BatchNumMessagesKey
static java.lang.String	BatchSizeKey	See .NET BatchSizeKey
static java.lang.String	BootstrapBrokersKey	See .NET BootstrapBrokersKey
static java.lang.String	BrokerAddressFamilyKey	See .NET BrokerAddressFamilyKey
static java.lang.String	BrokerAddressTtlKey	See .NET BootstrapBrokersKey
static java.lang.String	BrokerVersionFallbackKey	See .NET BrokerVersionFallbackKey
static java.lang.String	BuiltinFeaturesKey	See .NET BuiltinFeaturesKey
static java.lang.String	CheckCrcsKey	See .NET CheckCrcsKey
static java.lang.String	ClientIdKey	See .NET ClientIdKey
static java.lang.String	ClientRackKey	See .NET ClientRackKey
static java.lang.String	CompressionCodecKey	See .NET CompressionCodecKey
static java.lang.String	CompressionLevelKey	See .NET CompressionLevelKey
static java.lang.String	ConnectionsMaxIdleKey	See .NET ConnectionsMaxIdleKey
static java.lang.String	ConsumeCallbackMaxMessagesKey	See .NET ConsumeCallbackMaxMessagesKey
static java.lang.String	CoordinatorQueryIntervalKey	See .NET CoordinatorQueryIntervalKey
static java.lang.String	DebugKey	See .NET DebugKey
static java.lang.String	DeliveryReportOnlyErrorKey	See .NET DeliveryReportOnlyErrorKey
static java.lang.String	DumpMetadataKey	See .NET DumpMetadataKey
static java.lang.String	EnableAutoCommitKey	See .NET EnableAutoCommitKey
static java.lang.String	EnableAutoOffsetStoreKey	See .NET EnableAutoOffsetStoreKey
static java.lang.String	EnableGaplessGuaranteeKey	See .NET EnableGaplessGuaranteeKey
static java.lang.String	EnableIdempotenceKey	See .NET EnableIdempotenceKey
static java.lang.String	EnablePartitionEofKey	See .NET EnablePartitionEofKey
static java.lang.String	EnableRandomSeedKey	See .NET EnableRandomSeedKey
static java.lang.String	EnableSaslOauthbearerUnsecureJwtKey	See .NET EnableSaslOauthbearerUnsecureJwtKey
static java.lang.String	EnableSslCertificateVerificationKey	See .NET EnableSslCertificateVerificationKey
static java.lang.String	FetchErrorBackoffKey	See .NET FetchErrorBackoffKey
static java.lang.String	FetchMaxBytesKey	See .NET FetchMaxBytesKey
static java.lang.String	FetchMessageMaxBytesKey	See .NET FetchMessageMaxBytesKey
static java.lang.String	FetchMinBytesKey	See .NET FetchMinBytesKey
static java.lang.String	FetchWaitMaxKey	See .NET FetchWaitMaxKey
static java.lang.String	GroupIdKey	See .NET GroupIdKey
static java.lang.String	GroupInstanceIdKey	See .NET GroupInstanceIdKey
static java.lang.String	GroupProtocolTypeKey	See .NET GroupProtocolTypeKey
static java.lang.String	HeartbeatIntervalKey	See .NET HeartbeatIntervalKey
static java.lang.String	IntervalTerminationSignalKey	See .NET IntervalTerminationSignalKey
static java.lang.String	IsolationLevelKey	See .NET IsolationLevelKey
static java.lang.String	LogConnectionCloseKey	See .NET LogConnectionCloseKey
static java.lang.String	LogLevelKey	See .NET LogLevelKey
static java.lang.String	LogQueueKey	See .NET LogQueueKey
static java.lang.String	LogThreadNameKey	See .NET LogThreadNameKey
static java.lang.String	MaxInFlightRequestsPerConnectionKey	See .NET MaxInFlightRequestsPerConnectionKey
static java.lang.String	MaxPollIntervalKey	See .NET MaxPollIntervalKey
static java.lang.String	MessageCopyMaxBytesKey	See .NET MessageCopyMaxBytesKey
static java.lang.String	MessageMaxBytesKey	See .NET MessageMaxBytesKey
static java.lang.String	MessageSendMaxRetriesKey	See .NET MessageSendMaxRetriesKey
static java.lang.String	MessageTimeoutKey	See .NET MessageTimeoutKey
static java.lang.String	MetadataMaxAgeKey	See .NET MetadataMaxAgeKey
static java.lang.String	MetadataRequestTimeoutKey	See .NET MetadataRequestTimeoutKey
static java.lang.String	PartitionAssignmentStrategyKey	See .NET PartitionAssignmentStrategyKey
static java.lang.String	PartitionerKey	See .NET PartitionerKey
static java.lang.String	PluginLibraryPathsKey	See .NET PluginLibraryPathsKey
static java.lang.String	QueueBufferingBackpressureThresholdKey	See .NET QueueBufferingBackpressureThresholdKey
static java.lang.String	QueueBufferingMaxKbKey	See .NET QueueBufferingMaxKbKey
static java.lang.String	QueueBufferingMaxMessagesKey	See .NET QueueBufferingMaxMessagesKey
static java.lang.String	QueueBufferingMaxMsKey	See .NET QueueBufferingMaxMsKey
static java.lang.String	QueuedMaxMessagesKbKey	See .NET QueuedMaxMessagesKbKey
static java.lang.String	QueuedMinMessagesKey	See .NET QueuedMinMessagesKey
static java.lang.String	QueueingStrategyKey	See .NET QueueingStrategyKey
static java.lang.String	ReceiveMessageMaxBytesKey	See .NET ReceiveMessageMaxBytesKey
static java.lang.String	ReconnectBackoffKey	See .NET ReconnectBackoffKey
static java.lang.String	ReconnectBackoffMaxKey	See .NET ReconnectBackoffMaxKey
static java.lang.String	ReplicationFactorKey	See .NET ReplicationFactorKey
static java.lang.String	RequestRequiredAcksKey	See .NET RequestRequiredAcksKey
static java.lang.String	RequestTimeoutKey	See .NET RequestTimeoutKey
static java.lang.String	RetryBackoffKey	See .NET RetryBackoffKey
static java.lang.String	SaslKerberosKeytabKey	See .NET SaslKerberosKeytabKey
static java.lang.String	SaslKerberosKinitCmdKey	See .NET SaslKerberosKinitCmdKey
static java.lang.String	SaslKerberosMinTimeBeforeReloginKey	See .NET SaslKerberosMinTimeBeforeReloginKey
static java.lang.String	SaslKerberosPrincipalKey	See .NET SaslKerberosPrincipalKey
static java.lang.String	SaslKerberosServiceNameKey	See .NET SaslKerberosServiceNameKey
static java.lang.String	SaslMechanismKey	See .NET SaslMechanismKey
static java.lang.String	SaslOauthbearerClientIdKey	See .NET SaslOauthbearerClientIdKey
static java.lang.String	SaslOauthbearerClientSecretKey	See .NET SaslOauthbearerClientSecretKey
static java.lang.String	SaslOauthbearerConfigKey	See .NET SaslOauthbearerConfigKey
static java.lang.String	SaslOauthbearerExtensionsKey	See .NET SaslOauthbearerExtensionsKey
static java.lang.String	SaslOauthbearerMethodKey	See .NET SaslOauthbearerMethodKey
static java.lang.String	SaslOauthbearerScopeKey	See .NET SaslOauthbearerScopeKey
static java.lang.String	SaslOauthbearerTokenEndpointUrlKey	See .NET SaslOauthbearerTokenEndpointUrlKey
static java.lang.String	SaslPasswordKey	See .NET SaslPasswordKey
static java.lang.String	SaslUsernameKey	See .NET SaslUsernameKey
static java.lang.String	SecurityProtocolKey	See .NET SecurityProtocolKey
static java.lang.String	SessionTimeoutKey	See .NET SessionTimeoutKey
static java.lang.String	SocketConnectionSetupTimeoutKey	See .NET SocketConnectionSetupTimeoutKey
static java.lang.String	SocketKeepaliveEnableKey	See .NET SocketKeepaliveEnableKey
static java.lang.String	SocketMaxFailsKey	See .NET SocketMaxFailsKey
static java.lang.String	SocketNagleDisableKey	See .NET SocketNagleDisableKey
static java.lang.String	SocketReceiveBufferBytesKey	See .NET SocketReceiveBufferBytesKey
static java.lang.String	SocketSendBufferBytesKey	See .NET SocketSendBufferBytesKey
static java.lang.String	SocketTimeoutKey	See .NET SocketTimeoutKey
static java.lang.String	SslCACertificateStoresKey	See .NET SslCACertificateStoresKey
static java.lang.String	SslCAKey	See .NET SslCAKey
static java.lang.String	SslCALocationKey	See .NET SslCALocationKey
static java.lang.String	SslCAPemKey	See .NET SslCAPemKey
static java.lang.String	SslCertificateKey	See .NET SslCertificateKey
static java.lang.String	SslCertificateLocationKey	See .NET SslCertificateLocationKey
static java.lang.String	SslCertificatePemKey	See .NET SslCertificatePemKey
static java.lang.String	SslCipherSuitesKey	See .NET SslCipherSuitesKey
static java.lang.String	SslCrlLocationKey	See .NET SslCrlLocationKey
static java.lang.String	SslCurvesListKey	See .NET SslCurvesListKey
static java.lang.String	SslEndpointIdentificationAlgorithmKey	See .NET SslEndpointIdentificationAlgorithmKey
static java.lang.String	SslEngineIdKey	See .NET SslEngineIdKey
static java.lang.String	SslEngineLocationKey	See .NET SslEngineLocationKey
static java.lang.String	SslKeyKey	See .NET SslKeyKey
static java.lang.String	SslKeyLocationKey	See .NET SslKeyLocationKey
static java.lang.String	SslKeyPasswordKey	See .NET SslKeyPasswordKey
static java.lang.String	SslKeyPemKey	See .NET SslKeyPemKey
static java.lang.String	SslKeystoreLocationKey	See .NET SslKeystoreLocationKey
static java.lang.String	SslKeystorePasswordKey	See .NET SslKeystorePasswordKey
static java.lang.String	SslSisalgsListKey	See .NET SslSisalgsListKey
static java.lang.String	StatisticsIntervalKey	See .NET StatisticsIntervalKey
static java.lang.String	StickyPartitioningLingerKey	See .NET StickyPartitioningLingerKey
static java.lang.String	TopicBlackListKey	See .NET TopicBlackListKey
static java.lang.String	TopicCompressionCodecKey	See .NET TopicCompressionCodecKey
static java.lang.String	TopicCreateKey	See .NET TopicCreateKey
static java.lang.String	TopicMetadataPropagationMaxKey	See .NET TopicMetadataPropagationMaxKey
static java.lang.String	TopicMetadataRefreshFastIntervalKey	See .NET TopicMetadataRefreshFastIntervalKey
static java.lang.String	TopicMetadataRefreshIntervalKey	See .NET TopicMetadataRefreshIntervalKey
static java.lang.String	TopicMetadataRefreshSparseKey	See .NET TopicMetadataRefreshSparseKey
static java.lang.String	TransactionalIdKey	See .NET TransactionalIdKey
static java.lang.String	TransactionTimeoutKey	See .NET TransactionTimeoutKey

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
KafkaChannelConfiguration(KafkaConfiguration originalConf)	Duplicates a configuration

Method Summary

Modifier and Type	Method	Description
java.lang.String	getBootstrapBrokers()
java.lang.String	getClientId()
java.lang.String[]	getConfiguration()	The configuration parameters to use written as key=value
java.lang.String	getDebug()
boolean	getDumpMetadata()	True to dump metadata
java.lang.String	getGroupId()
java.lang.String	getProperty(KafkaChannelConfiguration.KafkaConfigurationType type, java.lang.String property)	Generic getter for all configuration properties related to librdkafka (see https://github.com/edenhill/librdkafka/blob/master/CONFIGURATION.md)
java.lang.Integer	getReplicationFactor()
boolean	getTopicCreate()	True to request a create topic
void	setBootstrapBrokers(java.lang.String brokers)	The bootstrap broker(s) to be used as Comma Separated Value(s)
void	setClientId(java.lang.String clientId)	The client id to be used
void	setDebug(java.lang.String debug)	The debug level (e.g.
void	setDumpMetadata(java.lang.Boolean value)	True to dump metadata
void	setGroupId(java.lang.String groupId)	The group id to be used
void	setProperty(KafkaChannelConfiguration.KafkaConfigurationType type, java.lang.String property, java.lang.String value)	Generic setter for all configuration properties related to librdkafka (see https://github.com/edenhill/librdkafka/blob/master/CONFIGURATION.md)
void	setReplicationFactor(java.lang.Integer value)	The replication factor to be used
void	setTopicCreate(java.lang.Boolean value)	True to request a create topic

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 java.lang.Object

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

Field Detail

ReplicationFactorKey

public static final java.lang.String ReplicationFactorKey

See .NET ReplicationFactorKey

See Also:

Constant Field Values

TopicCreateKey

public static final java.lang.String TopicCreateKey

See .NET TopicCreateKey

See Also:

Constant Field Values

DumpMetadataKey

public static final java.lang.String DumpMetadataKey

See .NET DumpMetadataKey

See Also:

Constant Field Values

BootstrapBrokersKey

public static final java.lang.String BootstrapBrokersKey

See .NET BootstrapBrokersKey

See Also:

Constant Field Values

DebugKey

public static final java.lang.String DebugKey

See .NET DebugKey

See Also:

Constant Field Values

ClientIdKey

public static final java.lang.String ClientIdKey

See .NET ClientIdKey

See Also:

Constant Field Values

GroupIdKey

public static final java.lang.String GroupIdKey

See .NET GroupIdKey

See Also:

Constant Field Values

BuiltinFeaturesKey

public static final java.lang.String BuiltinFeaturesKey

See .NET BuiltinFeaturesKey

See Also:

Constant Field Values

MessageMaxBytesKey

public static final java.lang.String MessageMaxBytesKey

See .NET MessageMaxBytesKey

See Also:

Constant Field Values

MessageCopyMaxBytesKey

public static final java.lang.String MessageCopyMaxBytesKey

See .NET MessageCopyMaxBytesKey

See Also:

Constant Field Values

ReceiveMessageMaxBytesKey

public static final java.lang.String ReceiveMessageMaxBytesKey

See .NET ReceiveMessageMaxBytesKey

See Also:

Constant Field Values

MaxInFlightRequestsPerConnectionKey

public static final java.lang.String MaxInFlightRequestsPerConnectionKey

See .NET MaxInFlightRequestsPerConnectionKey

See Also:

Constant Field Values

MetadataRequestTimeoutKey

public static final java.lang.String MetadataRequestTimeoutKey

See .NET MetadataRequestTimeoutKey

See Also:

Constant Field Values

TopicMetadataRefreshIntervalKey

public static final java.lang.String TopicMetadataRefreshIntervalKey

See .NET TopicMetadataRefreshIntervalKey

See Also:

Constant Field Values

MetadataMaxAgeKey

public static final java.lang.String MetadataMaxAgeKey

See .NET MetadataMaxAgeKey

See Also:

Constant Field Values

TopicMetadataRefreshFastIntervalKey

public static final java.lang.String TopicMetadataRefreshFastIntervalKey

See .NET TopicMetadataRefreshFastIntervalKey

See Also:

Constant Field Values

TopicMetadataRefreshSparseKey

public static final java.lang.String TopicMetadataRefreshSparseKey

See .NET TopicMetadataRefreshSparseKey

See Also:

Constant Field Values

TopicMetadataPropagationMaxKey

public static final java.lang.String TopicMetadataPropagationMaxKey

See .NET TopicMetadataPropagationMaxKey

See Also:

Constant Field Values

TopicBlackListKey

public static final java.lang.String TopicBlackListKey

See .NET TopicBlackListKey

See Also:

Constant Field Values

SocketTimeoutKey

public static final java.lang.String SocketTimeoutKey

See .NET SocketTimeoutKey

See Also:

Constant Field Values

SocketSendBufferBytesKey

public static final java.lang.String SocketSendBufferBytesKey

See .NET SocketSendBufferBytesKey

See Also:

Constant Field Values

SocketReceiveBufferBytesKey

public static final java.lang.String SocketReceiveBufferBytesKey

See .NET SocketReceiveBufferBytesKey

See Also:

Constant Field Values

SocketKeepaliveEnableKey

public static final java.lang.String SocketKeepaliveEnableKey

See .NET SocketKeepaliveEnableKey

See Also:

Constant Field Values

SocketNagleDisableKey

public static final java.lang.String SocketNagleDisableKey

See .NET SocketNagleDisableKey

See Also:

Constant Field Values

SocketMaxFailsKey

public static final java.lang.String SocketMaxFailsKey

See .NET SocketMaxFailsKey

See Also:

Constant Field Values

BrokerAddressTtlKey

public static final java.lang.String BrokerAddressTtlKey

See .NET BootstrapBrokersKey

See Also:

Constant Field Values

BrokerAddressFamilyKey

public static final java.lang.String BrokerAddressFamilyKey

See .NET BrokerAddressFamilyKey

See Also:

Constant Field Values

SocketConnectionSetupTimeoutKey

public static final java.lang.String SocketConnectionSetupTimeoutKey

See .NET SocketConnectionSetupTimeoutKey

See Also:

Constant Field Values

ConnectionsMaxIdleKey

public static final java.lang.String ConnectionsMaxIdleKey

See .NET ConnectionsMaxIdleKey

See Also:

Constant Field Values

ReconnectBackoffKey

public static final java.lang.String ReconnectBackoffKey

See .NET ReconnectBackoffKey

See Also:

Constant Field Values

ReconnectBackoffMaxKey

public static final java.lang.String ReconnectBackoffMaxKey

See .NET ReconnectBackoffMaxKey

See Also:

Constant Field Values

StatisticsIntervalKey

public static final java.lang.String StatisticsIntervalKey

See .NET StatisticsIntervalKey

See Also:

Constant Field Values

LogLevelKey

public static final java.lang.String LogLevelKey

See .NET LogLevelKey

See Also:

Constant Field Values

LogQueueKey

public static final java.lang.String LogQueueKey

See .NET LogQueueKey

See Also:

Constant Field Values

LogThreadNameKey

public static final java.lang.String LogThreadNameKey

See .NET LogThreadNameKey

See Also:

Constant Field Values

EnableRandomSeedKey

public static final java.lang.String EnableRandomSeedKey

See .NET EnableRandomSeedKey

See Also:

Constant Field Values

LogConnectionCloseKey

public static final java.lang.String LogConnectionCloseKey

See .NET LogConnectionCloseKey

See Also:

Constant Field Values

IntervalTerminationSignalKey

public static final java.lang.String IntervalTerminationSignalKey

See .NET IntervalTerminationSignalKey

See Also:

Constant Field Values

ApiVersionRequestKey

public static final java.lang.String ApiVersionRequestKey

See .NET ApiVersionRequestKey

See Also:

Constant Field Values

ApiVersionRequestTimeoutKey

public static final java.lang.String ApiVersionRequestTimeoutKey

See .NET ApiVersionRequestTimeoutKey

See Also:

Constant Field Values

ApiVersionFallbackKey

public static final java.lang.String ApiVersionFallbackKey

See .NET ApiVersionFallbackKey

See Also:

Constant Field Values

BrokerVersionFallbackKey

public static final java.lang.String BrokerVersionFallbackKey

See .NET BrokerVersionFallbackKey

See Also:

Constant Field Values

SecurityProtocolKey

public static final java.lang.String SecurityProtocolKey

See .NET SecurityProtocolKey

See Also:

Constant Field Values

SslCipherSuitesKey

public static final java.lang.String SslCipherSuitesKey

See .NET SslCipherSuitesKey

See Also:

Constant Field Values

SslCurvesListKey

public static final java.lang.String SslCurvesListKey

See .NET SslCurvesListKey

See Also:

Constant Field Values

SslSisalgsListKey

public static final java.lang.String SslSisalgsListKey

See .NET SslSisalgsListKey

See Also:

Constant Field Values

SslKeyLocationKey

public static final java.lang.String SslKeyLocationKey

See .NET SslKeyLocationKey

See Also:

Constant Field Values

SslKeyPasswordKey

public static final java.lang.String SslKeyPasswordKey

See .NET SslKeyPasswordKey

See Also:

Constant Field Values

SslKeyPemKey

public static final java.lang.String SslKeyPemKey

See .NET SslKeyPemKey

See Also:

Constant Field Values

SslKeyKey

public static final java.lang.String SslKeyKey

See .NET SslKeyKey

See Also:

Constant Field Values

SslCertificateLocationKey

public static final java.lang.String SslCertificateLocationKey

See .NET SslCertificateLocationKey

See Also:

Constant Field Values

SslCertificatePemKey

public static final java.lang.String SslCertificatePemKey

See .NET SslCertificatePemKey

See Also:

Constant Field Values

SslCertificateKey

public static final java.lang.String SslCertificateKey

See .NET SslCertificateKey

See Also:

Constant Field Values

SslCALocationKey

public static final java.lang.String SslCALocationKey

See .NET SslCALocationKey

See Also:

Constant Field Values

SslCAPemKey

public static final java.lang.String SslCAPemKey

See .NET SslCAPemKey

See Also:

Constant Field Values

SslCAKey

public static final java.lang.String SslCAKey

See .NET SslCAKey

See Also:

Constant Field Values

SslCACertificateStoresKey

public static final java.lang.String SslCACertificateStoresKey

See .NET SslCACertificateStoresKey

See Also:

Constant Field Values

SslCrlLocationKey

public static final java.lang.String SslCrlLocationKey

See .NET SslCrlLocationKey

See Also:

Constant Field Values

SslKeystoreLocationKey

public static final java.lang.String SslKeystoreLocationKey

See .NET SslKeystoreLocationKey

See Also:

Constant Field Values

SslKeystorePasswordKey

public static final java.lang.String SslKeystorePasswordKey

See .NET SslKeystorePasswordKey

See Also:

Constant Field Values

SslEngineLocationKey

public static final java.lang.String SslEngineLocationKey

See .NET SslEngineLocationKey

See Also:

Constant Field Values

SslEngineIdKey

public static final java.lang.String SslEngineIdKey

See .NET SslEngineIdKey

See Also:

Constant Field Values

EnableSslCertificateVerificationKey

public static final java.lang.String EnableSslCertificateVerificationKey

See .NET EnableSslCertificateVerificationKey

See Also:

Constant Field Values

SslEndpointIdentificationAlgorithmKey

public static final java.lang.String SslEndpointIdentificationAlgorithmKey

See .NET SslEndpointIdentificationAlgorithmKey

See Also:

Constant Field Values

SaslMechanismKey

public static final java.lang.String SaslMechanismKey

See .NET SaslMechanismKey

See Also:

Constant Field Values

SaslKerberosServiceNameKey

public static final java.lang.String SaslKerberosServiceNameKey

See .NET SaslKerberosServiceNameKey

See Also:

Constant Field Values

SaslKerberosPrincipalKey

public static final java.lang.String SaslKerberosPrincipalKey

See .NET SaslKerberosPrincipalKey

See Also:

Constant Field Values

SaslKerberosKinitCmdKey

public static final java.lang.String SaslKerberosKinitCmdKey

See .NET SaslKerberosKinitCmdKey

See Also:

Constant Field Values

SaslKerberosKeytabKey

public static final java.lang.String SaslKerberosKeytabKey

See .NET SaslKerberosKeytabKey

See Also:

Constant Field Values

SaslKerberosMinTimeBeforeReloginKey

public static final java.lang.String SaslKerberosMinTimeBeforeReloginKey

See .NET SaslKerberosMinTimeBeforeReloginKey

See Also:

Constant Field Values

SaslUsernameKey

public static final java.lang.String SaslUsernameKey

See .NET SaslUsernameKey

See Also:

Constant Field Values

SaslPasswordKey

public static final java.lang.String SaslPasswordKey

See .NET SaslPasswordKey

See Also:

Constant Field Values

SaslOauthbearerConfigKey

public static final java.lang.String SaslOauthbearerConfigKey

See .NET SaslOauthbearerConfigKey

See Also:

Constant Field Values

EnableSaslOauthbearerUnsecureJwtKey

public static final java.lang.String EnableSaslOauthbearerUnsecureJwtKey

See .NET EnableSaslOauthbearerUnsecureJwtKey

See Also:

Constant Field Values

SaslOauthbearerMethodKey

public static final java.lang.String SaslOauthbearerMethodKey

See .NET SaslOauthbearerMethodKey

See Also:

Constant Field Values

SaslOauthbearerClientIdKey

public static final java.lang.String SaslOauthbearerClientIdKey

See .NET SaslOauthbearerClientIdKey

See Also:

Constant Field Values

SaslOauthbearerClientSecretKey

public static final java.lang.String SaslOauthbearerClientSecretKey

See .NET SaslOauthbearerClientSecretKey

See Also:

Constant Field Values

SaslOauthbearerScopeKey

public static final java.lang.String SaslOauthbearerScopeKey

See .NET SaslOauthbearerScopeKey

See Also:

Constant Field Values

SaslOauthbearerExtensionsKey

public static final java.lang.String SaslOauthbearerExtensionsKey

See .NET SaslOauthbearerExtensionsKey

See Also:

Constant Field Values

SaslOauthbearerTokenEndpointUrlKey

public static final java.lang.String SaslOauthbearerTokenEndpointUrlKey

See .NET SaslOauthbearerTokenEndpointUrlKey

See Also:

Constant Field Values

PluginLibraryPathsKey

public static final java.lang.String PluginLibraryPathsKey

See .NET PluginLibraryPathsKey

See Also:

Constant Field Values

GroupInstanceIdKey

public static final java.lang.String GroupInstanceIdKey

See .NET GroupInstanceIdKey

See Also:

Constant Field Values

PartitionAssignmentStrategyKey

public static final java.lang.String PartitionAssignmentStrategyKey

See .NET PartitionAssignmentStrategyKey

See Also:

Constant Field Values

SessionTimeoutKey

public static final java.lang.String SessionTimeoutKey

See .NET SessionTimeoutKey

See Also:

Constant Field Values

HeartbeatIntervalKey

public static final java.lang.String HeartbeatIntervalKey

See .NET HeartbeatIntervalKey

See Also:

Constant Field Values

GroupProtocolTypeKey

public static final java.lang.String GroupProtocolTypeKey

See .NET GroupProtocolTypeKey

See Also:

Constant Field Values

CoordinatorQueryIntervalKey

public static final java.lang.String CoordinatorQueryIntervalKey

See .NET CoordinatorQueryIntervalKey

See Also:

Constant Field Values

MaxPollIntervalKey

public static final java.lang.String MaxPollIntervalKey

See .NET MaxPollIntervalKey

See Also:

Constant Field Values

EnableAutoCommitKey

public static final java.lang.String EnableAutoCommitKey

See .NET EnableAutoCommitKey

See Also:

Constant Field Values

AutoCommitIntervalKey

public static final java.lang.String AutoCommitIntervalKey

See .NET AutoCommitIntervalKey

See Also:

Constant Field Values

EnableAutoOffsetStoreKey

public static final java.lang.String EnableAutoOffsetStoreKey

See .NET EnableAutoOffsetStoreKey

See Also:

Constant Field Values

QueuedMinMessagesKey

public static final java.lang.String QueuedMinMessagesKey

See .NET QueuedMinMessagesKey

See Also:

Constant Field Values

QueuedMaxMessagesKbKey

public static final java.lang.String QueuedMaxMessagesKbKey

See .NET QueuedMaxMessagesKbKey

See Also:

Constant Field Values

FetchWaitMaxKey

public static final java.lang.String FetchWaitMaxKey

See .NET FetchWaitMaxKey

See Also:

Constant Field Values

FetchMessageMaxBytesKey

public static final java.lang.String FetchMessageMaxBytesKey

See .NET FetchMessageMaxBytesKey

See Also:

Constant Field Values

FetchMaxBytesKey

public static final java.lang.String FetchMaxBytesKey

See .NET FetchMaxBytesKey

See Also:

Constant Field Values

FetchMinBytesKey

public static final java.lang.String FetchMinBytesKey

See .NET FetchMinBytesKey

See Also:

Constant Field Values

FetchErrorBackoffKey

public static final java.lang.String FetchErrorBackoffKey

See .NET FetchErrorBackoffKey

See Also:

Constant Field Values

IsolationLevelKey

public static final java.lang.String IsolationLevelKey

See .NET IsolationLevelKey

See Also:

Constant Field Values

EnablePartitionEofKey

public static final java.lang.String EnablePartitionEofKey

See .NET EnablePartitionEofKey

See Also:

Constant Field Values

CheckCrcsKey

public static final java.lang.String CheckCrcsKey

See .NET CheckCrcsKey

See Also:

Constant Field Values

AllowAutoCreateTopicsKey

public static final java.lang.String AllowAutoCreateTopicsKey

See .NET AllowAutoCreateTopicsKey

See Also:

Constant Field Values

ClientRackKey

public static final java.lang.String ClientRackKey

See .NET ClientRackKey

See Also:

Constant Field Values

TransactionalIdKey

public static final java.lang.String TransactionalIdKey

See .NET TransactionalIdKey

See Also:

Constant Field Values

TransactionTimeoutKey

public static final java.lang.String TransactionTimeoutKey

See .NET TransactionTimeoutKey

See Also:

Constant Field Values

EnableIdempotenceKey

public static final java.lang.String EnableIdempotenceKey

See .NET EnableIdempotenceKey

See Also:

Constant Field Values

EnableGaplessGuaranteeKey

public static final java.lang.String EnableGaplessGuaranteeKey

See .NET EnableGaplessGuaranteeKey

See Also:

Constant Field Values

QueueBufferingMaxMessagesKey

public static final java.lang.String QueueBufferingMaxMessagesKey

See .NET QueueBufferingMaxMessagesKey

See Also:

Constant Field Values

QueueBufferingMaxKbKey

public static final java.lang.String QueueBufferingMaxKbKey

See .NET QueueBufferingMaxKbKey

See Also:

Constant Field Values

QueueBufferingMaxMsKey

public static final java.lang.String QueueBufferingMaxMsKey

See .NET QueueBufferingMaxMsKey

See Also:

Constant Field Values

MessageSendMaxRetriesKey

public static final java.lang.String MessageSendMaxRetriesKey

See .NET MessageSendMaxRetriesKey

See Also:

Constant Field Values

RetryBackoffKey

public static final java.lang.String RetryBackoffKey

See .NET RetryBackoffKey

See Also:

Constant Field Values

QueueBufferingBackpressureThresholdKey

public static final java.lang.String QueueBufferingBackpressureThresholdKey

See .NET QueueBufferingBackpressureThresholdKey

See Also:

Constant Field Values

CompressionCodecKey

public static final java.lang.String CompressionCodecKey

See .NET CompressionCodecKey

See Also:

Constant Field Values

BatchNumMessagesKey

public static final java.lang.String BatchNumMessagesKey

See .NET BatchNumMessagesKey

See Also:

Constant Field Values

BatchSizeKey

public static final java.lang.String BatchSizeKey

See .NET BatchSizeKey

See Also:

Constant Field Values

DeliveryReportOnlyErrorKey

public static final java.lang.String DeliveryReportOnlyErrorKey

See .NET DeliveryReportOnlyErrorKey

See Also:

Constant Field Values

StickyPartitioningLingerKey

public static final java.lang.String StickyPartitioningLingerKey

See .NET StickyPartitioningLingerKey

See Also:

Constant Field Values

RequestRequiredAcksKey

public static final java.lang.String RequestRequiredAcksKey

See .NET RequestRequiredAcksKey

See Also:

Constant Field Values

RequestTimeoutKey

public static final java.lang.String RequestTimeoutKey

See .NET RequestTimeoutKey

See Also:

Constant Field Values

MessageTimeoutKey

public static final java.lang.String MessageTimeoutKey

See .NET MessageTimeoutKey

See Also:

Constant Field Values

QueueingStrategyKey

public static final java.lang.String QueueingStrategyKey

See .NET QueueingStrategyKey

See Also:

Constant Field Values

PartitionerKey

public static final java.lang.String PartitionerKey

See .NET PartitionerKey

See Also:

Constant Field Values

TopicCompressionCodecKey

public static final java.lang.String TopicCompressionCodecKey

See .NET TopicCompressionCodecKey

See Also:

Constant Field Values

CompressionLevelKey

public static final java.lang.String CompressionLevelKey

See .NET CompressionLevelKey

See Also:

Constant Field Values

AutoOffsetResetKey

public static final java.lang.String AutoOffsetResetKey

See .NET AutoOffsetResetKey

See Also:

Constant Field Values

ConsumeCallbackMaxMessagesKey

public static final java.lang.String ConsumeCallbackMaxMessagesKey

See .NET ConsumeCallbackMaxMessagesKey

See Also:

Constant Field Values

Constructor Detail

KafkaChannelConfiguration

public KafkaChannelConfiguration(KafkaConfiguration originalConf)

Duplicates a configuration

Parameters:

originalConf - KafkaConfiguration to duplicate

Method Detail

getClientId

public java.lang.String getClientId()

Returns:

The client id to be used

setClientId

public void setClientId(java.lang.String clientId)

The client id to be used

Parameters:

clientId - The client id to be used

getGroupId

public java.lang.String getGroupId()

Returns:

The group id to be used

setGroupId

public void setGroupId(java.lang.String groupId)

The group id to be used

Parameters:

groupId - The group id to be used

getDebug

public java.lang.String getDebug()

Returns:

The debug level (e.g. metadata,topic,msg,broker)

setDebug

public void setDebug(java.lang.String debug)

The debug level (e.g. metadata,topic,msg,broker)

Parameters:

debug - The debug level (e.g. metadata,topic,msg,broker)

getBootstrapBrokers

public java.lang.String getBootstrapBrokers()

Returns:

The bootstrap broker(s) to be used as Comma Separated Value(s)

setBootstrapBrokers

public void setBootstrapBrokers(java.lang.String brokers)

The bootstrap broker(s) to be used as Comma Separated Value(s)

Parameters:

brokers - The bootstrap broker(s) to be used as Comma Separated Value(s)

getReplicationFactor

public java.lang.Integer getReplicationFactor()

Returns:

The replication factor to be used

setReplicationFactor

public void setReplicationFactor(java.lang.Integer value)

The replication factor to be used

Parameters:

value - The replication factor to be used

getTopicCreate

public boolean getTopicCreate()

True to request a create topic

Returns:

True to request a create topic

setTopicCreate

public void setTopicCreate(java.lang.Boolean value)

True to request a create topic

Parameters:

value - True to request a create topic

getDumpMetadata

public boolean getDumpMetadata()

True to dump metadata

Returns:

True to dump metadata

setDumpMetadata

public void setDumpMetadata(java.lang.Boolean value)

True to dump metadata

Parameters:

value - True to dump metadata

getProperty

public java.lang.String getProperty(KafkaChannelConfiguration.KafkaConfigurationType type,
                                    java.lang.String property)

Generic getter for all configuration properties related to librdkafka (see https://github.com/edenhill/librdkafka/blob/master/CONFIGURATION.md)

Parameters:

type - KafkaChannelConfiguration.KafkaConfigurationType type

property - The property name

Returns:

The property value

setProperty

public void setProperty(KafkaChannelConfiguration.KafkaConfigurationType type,
                        java.lang.String property,
                        java.lang.String value)

Generic setter for all configuration properties related to librdkafka (see https://github.com/edenhill/librdkafka/blob/master/CONFIGURATION.md)

Parameters:

type - KafkaChannelConfiguration.KafkaConfigurationType type

property - The property name

value - The property value

getConfiguration

public java.lang.String[] getConfiguration()
                                    throws java.lang.IllegalArgumentException

Description copied from interface: IConfiguration

The configuration parameters to use written as key=value

Specified by:

getConfiguration in interface IConfiguration

Overrides:

getConfiguration in class BaseConfiguration

Returns:

an array of String with key=value pairs

Throws:

java.lang.IllegalArgumentException - if something was not right or compatible in the configuration properties