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, Marius Bogoevici

Constructor Summary

Constructors

Constructor and Description
KafkaProducerOptionsMixin()

Method Summary

Methods

Modifier and Type	Method and Description
int	getAckTimeoutOnServer()
int	getBatchBytes()
int	getBufferMemory()
java.lang.String	getCompressionCodec()
int	getMaxBufferTime()
int	getMaxRequestSize()
int	getMaxSendRetries()
int	getReceiveBufferBytes()
long	getReconnectBackoff()
int	getRequestRequiredAck()
long	getRetryBackoff()
int	getSendBufferBytes()
int	getTopicMetadataFetchTimeout()
int	getTopicMetadataRefreshInterval()
boolean	isBlockOnBufferFull()
boolean	isRequestRequiredAckValid()
boolean	isValidCompressionCodec()
void	setAckTimeoutOnServer(int ackTimeoutOnServer)
void	setBatchBytes(int batchBytes)
void	setBlockOnBufferFull(boolean blockOnBufferFull)
void	setBufferMemory(int bufferMemory)
void	setCompressionCodec(java.lang.String compressionCodec)
void	setMaxBufferTime(int maxBufferTime)
void	setMaxRequestSize(int maxRequestSize)
void	setMaxSendRetries(int maxSendRetries)
void	setReceiveBufferBytes(int receiveBufferBytes)
void	setReconnectBackoff(long reconnectBackoff)
void	setRequestRequiredAck(int requestRequiredAck)
void	setRetryBackoff(long retryBackoff)
void	setSendBufferBytes(int sendBufferBytes)
void	setTopicMetadataFetchTimeout(int topicMetadataFetchTimeout)
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()

getBufferMemory

public int getBufferMemory()

setBufferMemory

public void setBufferMemory(int bufferMemory)

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()

getMaxSendRetries

public int getMaxSendRetries()

setMaxSendRetries

public void setMaxSendRetries(int maxSendRetries)

getBatchBytes

public int getBatchBytes()

setBatchBytes

public void setBatchBytes(int batchBytes)

getMaxRequestSize

public int getMaxRequestSize()

setMaxRequestSize

public void setMaxRequestSize(int maxRequestSize)

getMaxBufferTime

public int getMaxBufferTime()

setMaxBufferTime

public void setMaxBufferTime(int maxBufferTime)

getReceiveBufferBytes

public int getReceiveBufferBytes()

setReceiveBufferBytes

public void setReceiveBufferBytes(int receiveBufferBytes)

getSendBufferBytes

public int getSendBufferBytes()

setSendBufferBytes

public void setSendBufferBytes(int sendBufferBytes)

getAckTimeoutOnServer

public int getAckTimeoutOnServer()

setAckTimeoutOnServer

public void setAckTimeoutOnServer(int ackTimeoutOnServer)

isBlockOnBufferFull

public boolean isBlockOnBufferFull()

setBlockOnBufferFull

public void setBlockOnBufferFull(boolean blockOnBufferFull)

getTopicMetadataRefreshInterval

public int getTopicMetadataRefreshInterval()

setTopicMetadataRefreshInterval

public void setTopicMetadataRefreshInterval(int topicMetadataRefreshInterval)

getTopicMetadataFetchTimeout

public int getTopicMetadataFetchTimeout()

setTopicMetadataFetchTimeout

public void setTopicMetadataFetchTimeout(int topicMetadataFetchTimeout)

getReconnectBackoff

public long getReconnectBackoff()

setReconnectBackoff

public void setReconnectBackoff(long reconnectBackoff)

getRetryBackoff

public long getRetryBackoff()

setRetryBackoff

public void setRetryBackoff(long retryBackoff)