Package org.openspaces.admin.di

Class KafkaConfiguration

java.lang.Object

org.openspaces.admin.di.KafkaConfiguration

public class KafkaConfiguration
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final String	AUTO_OFFSET_RESET_CONFIG
static final String	DEFAULT_AUTO_OFFSET_RESET_CONFIG
static final String	DEFAULT_COMMAND_CLASS
static final Boolean	DEFAULT_ENABLE_AUTO_COMMIT_CONFIG
static final long	DEFAULT_KAFKA_ADMIN_API_CALLS_TIMEOUT_SECONDS
static final String	DEFAULT_KEY_DESERIALIZER
static final int	DEFAULT_MAX_POLL_RECORDS
static final int	DEFAULT_PARALLELISM
static final int	DEFAULT_RECEIVE_BUFFER_CONFIG
static final String	DEFAULT_TOPIC_CONFIGURATION
static final int	DEFAULT_TOPIC_REPLICATION_FACTOR
static final String	DEFAULT_VALIDATE_CLASS
static final String	DEFAULT_VALUE_DESERIALIZER
static final String	ENABLE_AUTO_COMMIT_CONFIG
static final String	KEY_DESERIALIZER
static final String	MAX_POLL_RECORDS
static final String	RECEIVE_BUFFER_BYTES
static final String	VALUE_DESERIALIZER

Constructor Summary

Constructors

Constructor	Description
KafkaConfiguration()

Method Summary

Modifier and Type	Method	Description
String	getAutoOffsetResetConfig()
String	getBootstrapServers()
Boolean	getEnableAutoCommitConfig()
Long	getKafkaAdminClientApiCallsTimeoutSeconds()
Map<String,Object>	getKafkaConsumerConfiguration()
Integer	getKafkaMaxPollRecords()
String	getKafkaMessageCommandClass()
String	getKafkaMessageValidateClass()
Integer	getKafkaReceiveBufferConfig()
String	getKeyDeserializer()
Integer	getParallelism()
String	getTopicName()
Short	getTopicReplicationFactor()
String	getValueDeserializer()
void	setBootstrapServers(String bootstrapServers)
void	setKafkaAdminClientApiCallsTimeoutSeconds(Long kafkaAdminClientApiCallsTimeoutSeconds)
void	setKafkaMaxPollRecords(Integer maxPollRecords)
void	setKafkaMessageCommandClass(String kafkaMessageCommandClass)
void	setKafkaMessageValidateClass(String kafkaMessageValidateClass)
void	setKafkaReceiveBufferConfig(Integer receiveBufferConfig)
Integer	setParallelism(Integer parallelism)
void	setTopicName(String topicName)
void	setTopicReplicationFactor(Short topicReplicationFactor)
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

MAX_POLL_RECORDS

public static final String MAX_POLL_RECORDS

See Also:

• Constant Field Values

RECEIVE_BUFFER_BYTES

public static final String RECEIVE_BUFFER_BYTES

See Also:

• Constant Field Values

KEY_DESERIALIZER

public static final String KEY_DESERIALIZER

See Also:

• Constant Field Values

VALUE_DESERIALIZER

public static final String VALUE_DESERIALIZER

See Also:

• Constant Field Values

ENABLE_AUTO_COMMIT_CONFIG

public static final String ENABLE_AUTO_COMMIT_CONFIG

See Also:

• Constant Field Values

AUTO_OFFSET_RESET_CONFIG

public static final String AUTO_OFFSET_RESET_CONFIG

See Also:

• Constant Field Values

DEFAULT_MAX_POLL_RECORDS

public static final int DEFAULT_MAX_POLL_RECORDS

See Also:

• Constant Field Values

DEFAULT_RECEIVE_BUFFER_CONFIG

public static final int DEFAULT_RECEIVE_BUFFER_CONFIG

See Also:

• Constant Field Values

DEFAULT_TOPIC_REPLICATION_FACTOR

public static final int DEFAULT_TOPIC_REPLICATION_FACTOR

See Also:

• Constant Field Values

DEFAULT_PARALLELISM

public static final int DEFAULT_PARALLELISM

See Also:

• Constant Field Values

DEFAULT_KAFKA_ADMIN_API_CALLS_TIMEOUT_SECONDS

public static final long DEFAULT_KAFKA_ADMIN_API_CALLS_TIMEOUT_SECONDS

See Also:

• Constant Field Values

DEFAULT_KEY_DESERIALIZER

public static final String DEFAULT_KEY_DESERIALIZER

See Also:

• Constant Field Values

DEFAULT_VALUE_DESERIALIZER

public static final String DEFAULT_VALUE_DESERIALIZER

See Also:

• Constant Field Values

DEFAULT_COMMAND_CLASS

public static final String DEFAULT_COMMAND_CLASS

See Also:

• Constant Field Values

DEFAULT_VALIDATE_CLASS

public static final String DEFAULT_VALIDATE_CLASS

See Also:

• Constant Field Values

DEFAULT_TOPIC_CONFIGURATION

public static final String DEFAULT_TOPIC_CONFIGURATION

See Also:

• Constant Field Values

DEFAULT_AUTO_OFFSET_RESET_CONFIG

public static final String DEFAULT_AUTO_OFFSET_RESET_CONFIG

See Also:

• Constant Field Values

DEFAULT_ENABLE_AUTO_COMMIT_CONFIG

public static final Boolean DEFAULT_ENABLE_AUTO_COMMIT_CONFIG

Constructor Details

KafkaConfiguration

public KafkaConfiguration()

Method Details

getTopicName

public String getTopicName()

getBootstrapServers

public String getBootstrapServers()

getParallelism

public Integer getParallelism()

getTopicReplicationFactor

public Short getTopicReplicationFactor()

getKafkaMessageCommandClass

public String getKafkaMessageCommandClass()

getKafkaMessageValidateClass

public String getKafkaMessageValidateClass()

getKafkaConsumerConfiguration

public Map<String,Object> getKafkaConsumerConfiguration()

getKafkaMaxPollRecords

public Integer getKafkaMaxPollRecords()

getKafkaReceiveBufferConfig

public Integer getKafkaReceiveBufferConfig()

setKafkaMaxPollRecords

public void setKafkaMaxPollRecords(Integer maxPollRecords)

setKafkaReceiveBufferConfig

public void setKafkaReceiveBufferConfig(Integer receiveBufferConfig)

getKeyDeserializer

public String getKeyDeserializer()

getValueDeserializer

public String getValueDeserializer()

getEnableAutoCommitConfig

public Boolean getEnableAutoCommitConfig()

getAutoOffsetResetConfig

public String getAutoOffsetResetConfig()

setParallelism

public Integer setParallelism(Integer parallelism)

setTopicName

public void setTopicName(String topicName)

setBootstrapServers

public void setBootstrapServers(String bootstrapServers)

setTopicReplicationFactor

public void setTopicReplicationFactor(Short topicReplicationFactor)

setKafkaMessageCommandClass

public void setKafkaMessageCommandClass(String kafkaMessageCommandClass)

setKafkaMessageValidateClass

public void setKafkaMessageValidateClass(String kafkaMessageValidateClass)

getKafkaAdminClientApiCallsTimeoutSeconds

public Long getKafkaAdminClientApiCallsTimeoutSeconds()

setKafkaAdminClientApiCallsTimeoutSeconds

public void setKafkaAdminClientApiCallsTimeoutSeconds(Long kafkaAdminClientApiCallsTimeoutSeconds)

toString

public String toString()

Overrides:

toString in class Object