org.springframework.integration.x.kafka

Class KafkaProducerOptionsMixin

java.lang.Object

org.springframework.integration.x.kafka.KafkaProducerOptionsMixin

public class KafkaProducerOptionsMixin
extends java.lang.Object

Module options for Kafka Producer configuration.

Author:

Ilayaperumal Gopinathan

Constructor Summary

Constructors

Constructor and Description
KafkaProducerOptionsMixin()

Method Summary

Methods

Modifier and Type	Method and Description
int	getBatchCount()
java.lang.String	getCompressedTopics()
java.lang.String	getCompressionCodec()
int	getEnqueueTimeout()
int	getMaxBufferMsgs()
int	getMaxBufferTime()
int	getMaxSendRetries()
java.lang.String	getProducerType()
int	getRequestRequiredAck()
int	getRequestTimeout()
int	getRetryBackoff()
int	getSocketBufferSize()
int	getTopicMetadataRefreshInterval()
boolean	isProducerTypeValid()
boolean	isRequestRequiredAckValid()
boolean	isValidCompressionCodec()
void	setBatchCount(int batchCount)
void	setCompressedTopics(java.lang.String compressedTopics)
void	setCompressionCodec(java.lang.String compressionCodec)
void	setEnqueueTimeout(int enqueueTimeout)
void	setMaxBufferMsgs(int maxBufferMsgs)
void	setMaxBufferTime(int maxBufferTime)
void	setMaxSendRetries(int maxSendRetries)
void	setProducerType(java.lang.String producerType)
void	setRequestRequiredAck(int requestRequiredAck)
void	setRequestTimeout(int requestTimeout)
void	setRetryBackoff(int retryBackoff)
void	setSocketBufferSize(int socketBufferSize)
void	setTopicMetadataRefreshInterval(int topicMetadataRefreshInterval)

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaProducerOptionsMixin

public KafkaProducerOptionsMixin()

Method Detail

getRequestRequiredAck

public int getRequestRequiredAck()

setRequestRequiredAck

public void setRequestRequiredAck(int requestRequiredAck)

isRequestRequiredAckValid

@AssertTrue(message="requestRequiredAck can have values 0, 1 or -1")
public boolean isRequestRequiredAckValid()

getRequestTimeout

public int getRequestTimeout()

setRequestTimeout

public void setRequestTimeout(int requestTimeout)

getProducerType

public java.lang.String getProducerType()

setProducerType

public void setProducerType(java.lang.String producerType)

isProducerTypeValid

@AssertTrue(message="produer type can either be sync or async")
public boolean isProducerTypeValid()

getCompressionCodec

public java.lang.String getCompressionCodec()

setCompressionCodec

public void setCompressionCodec(java.lang.String compressionCodec)

isValidCompressionCodec

@AssertTrue(message="compression codec can be \'none\', \'gzip\' or \'snappy\'")
public boolean isValidCompressionCodec()

getCompressedTopics

public java.lang.String getCompressedTopics()

setCompressedTopics

public void setCompressedTopics(java.lang.String compressedTopics)

getMaxSendRetries

public int getMaxSendRetries()

setMaxSendRetries

public void setMaxSendRetries(int maxSendRetries)

getRetryBackoff

public int getRetryBackoff()

setRetryBackoff

public void setRetryBackoff(int retryBackoff)

getTopicMetadataRefreshInterval

public int getTopicMetadataRefreshInterval()

setTopicMetadataRefreshInterval

public void setTopicMetadataRefreshInterval(int topicMetadataRefreshInterval)

getMaxBufferTime

public int getMaxBufferTime()

setMaxBufferTime

public void setMaxBufferTime(int maxBufferTime)

getMaxBufferMsgs

public int getMaxBufferMsgs()

setMaxBufferMsgs

public void setMaxBufferMsgs(int maxBufferMsgs)

getEnqueueTimeout

public int getEnqueueTimeout()

setEnqueueTimeout

public void setEnqueueTimeout(int enqueueTimeout)

getBatchCount

public int getBatchCount()

setBatchCount

public void setBatchCount(int batchCount)

getSocketBufferSize

public int getSocketBufferSize()

setSocketBufferSize

public void setSocketBufferSize(int socketBufferSize)