org.springframework.cloud.stream.binder.kafka.config

Class KafkaBinderConfigurationProperties

java.lang.Object

org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties

@ConfigurationProperties(prefix="spring.cloud.stream.kafka.binder")
public class KafkaBinderConfigurationProperties
extends Object

Author:

David Turanski, Ilayaperumal Gopinathan, Marius Bogoevici, Soby Chacko

Constructor Summary

Constructors

Constructor and Description
KafkaBinderConfigurationProperties()

Method Summary

Modifier and Type	Method and Description
String[]	getBrokers()
Map<String,String>	getConfiguration()
int	getFetchSize()
String[]	getHeaders()
JaasLoginModuleConfiguration	getJaas()
String	getKafkaConnectionString()
int	getMaxWait()
int	getMinPartitionCount()
int	getOffsetUpdateCount()
int	getOffsetUpdateShutdownTimeout()
int	getOffsetUpdateTimeWindow()
int	getQueueSize()
int	getReplicationFactor()
int	getRequiredAcks()
int	getSocketBufferSize()
String	getZkConnectionString()
int	getZkConnectionTimeout()
String[]	getZkNodes()
int	getZkSessionTimeout()
boolean	isAutoAddPartitions()
boolean	isAutoCreateTopics()
void	setAutoAddPartitions(boolean autoAddPartitions)
void	setAutoCreateTopics(boolean autoCreateTopics)
void	setBrokers(String... brokers)
void	setConfiguration(Map<String,String> configuration)
void	setDefaultBrokerPort(String defaultBrokerPort)
void	setDefaultZkPort(String defaultZkPort)
void	setFetchSize(int fetchSize)
void	setHeaders(String... headers)
void	setJaas(JaasLoginModuleConfiguration jaas)
void	setMaxWait(int maxWait)
void	setMinPartitionCount(int minPartitionCount)
void	setOffsetUpdateCount(int offsetUpdateCount)
void	setOffsetUpdateShutdownTimeout(int offsetUpdateShutdownTimeout)
void	setOffsetUpdateTimeWindow(int offsetUpdateTimeWindow)
void	setQueueSize(int queueSize)
void	setReplicationFactor(int replicationFactor)
void	setRequiredAcks(int requiredAcks)
void	setSocketBufferSize(int socketBufferSize)
void	setZkConnectionTimeout(int zkConnectionTimeout)
void	setZkNodes(String... zkNodes)
void	setZkSessionTimeout(int zkSessionTimeout)

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaBinderConfigurationProperties

public KafkaBinderConfigurationProperties()

Method Detail

getZkConnectionString

public String getZkConnectionString()

getKafkaConnectionString

public String getKafkaConnectionString()

getHeaders

public String[] getHeaders()

getOffsetUpdateTimeWindow

public int getOffsetUpdateTimeWindow()

getOffsetUpdateCount

public int getOffsetUpdateCount()

getOffsetUpdateShutdownTimeout

public int getOffsetUpdateShutdownTimeout()

getZkNodes

public String[] getZkNodes()

setZkNodes

public void setZkNodes(String... zkNodes)

setDefaultZkPort

public void setDefaultZkPort(String defaultZkPort)

getBrokers

public String[] getBrokers()

setBrokers

public void setBrokers(String... brokers)

setDefaultBrokerPort

public void setDefaultBrokerPort(String defaultBrokerPort)

setHeaders

public void setHeaders(String... headers)

setOffsetUpdateTimeWindow

public void setOffsetUpdateTimeWindow(int offsetUpdateTimeWindow)

setOffsetUpdateCount

public void setOffsetUpdateCount(int offsetUpdateCount)

setOffsetUpdateShutdownTimeout

public void setOffsetUpdateShutdownTimeout(int offsetUpdateShutdownTimeout)

getZkSessionTimeout

public int getZkSessionTimeout()

setZkSessionTimeout

public void setZkSessionTimeout(int zkSessionTimeout)

getZkConnectionTimeout

public int getZkConnectionTimeout()

setZkConnectionTimeout

public void setZkConnectionTimeout(int zkConnectionTimeout)

getMaxWait

public int getMaxWait()

setMaxWait

public void setMaxWait(int maxWait)

getRequiredAcks

public int getRequiredAcks()

setRequiredAcks

public void setRequiredAcks(int requiredAcks)

getReplicationFactor

public int getReplicationFactor()

setReplicationFactor

public void setReplicationFactor(int replicationFactor)

getFetchSize

public int getFetchSize()

setFetchSize

public void setFetchSize(int fetchSize)

getMinPartitionCount

public int getMinPartitionCount()

setMinPartitionCount

public void setMinPartitionCount(int minPartitionCount)

getQueueSize

public int getQueueSize()

setQueueSize

public void setQueueSize(int queueSize)

isAutoCreateTopics

public boolean isAutoCreateTopics()

setAutoCreateTopics

public void setAutoCreateTopics(boolean autoCreateTopics)

isAutoAddPartitions

public boolean isAutoAddPartitions()

setAutoAddPartitions

public void setAutoAddPartitions(boolean autoAddPartitions)

getSocketBufferSize

public int getSocketBufferSize()

setSocketBufferSize

public void setSocketBufferSize(int socketBufferSize)

getConfiguration

public Map<String,String> getConfiguration()

setConfiguration

public void setConfiguration(Map<String,String> configuration)

getJaas

public JaasLoginModuleConfiguration getJaas()

setJaas

public void setJaas(JaasLoginModuleConfiguration jaas)