org.springframework.integration.x.kafka

Class KafkaConsumerOptionsMixin

java.lang.Object

org.springframework.integration.x.kafka.KafkaConsumerOptionsMixin

public class KafkaConsumerOptionsMixin
extends java.lang.Object

Module options for Kafka consumer configuration.

Author:

Ilayaperumal Gopinathan

Constructor Summary

Constructors

Constructor and Description
KafkaConsumerOptionsMixin()

Method Summary

Methods

Modifier and Type	Method and Description
java.lang.String	getAutoOffsetReset()
int	getFetchMaxBytes()
int	getFetchMaxWait()
int	getFetchMinBytes()
int	getSocketBufferBytes()
int	getSocketTimeout()
boolean	isValidAutoOffsetReset()
void	setAutoOffsetReset(java.lang.String autoOffsetReset)
void	setFetchMaxBytes(int fetchMaxBytes)
void	setFetchMaxWait(int fetchMaxWait)
void	setFetchMinBytes(int fetchMinBytes)
void	setSocketBufferBytes(int socketBufferBytes)
void	setSocketTimeout(int socketTimeout)

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaConsumerOptionsMixin

public KafkaConsumerOptionsMixin()

Method Detail

getSocketTimeout

public int getSocketTimeout()

setSocketTimeout

public void setSocketTimeout(int socketTimeout)

getSocketBufferBytes

public int getSocketBufferBytes()

setSocketBufferBytes

public void setSocketBufferBytes(int socketBufferBytes)

getFetchMaxBytes

public int getFetchMaxBytes()

setFetchMaxBytes

public void setFetchMaxBytes(int fetchMaxBytes)

getFetchMinBytes

public int getFetchMinBytes()

setFetchMinBytes

public void setFetchMinBytes(int fetchMinBytes)

getFetchMaxWait

public int getFetchMaxWait()

setFetchMaxWait

public void setFetchMaxWait(int fetchMaxWait)

getAutoOffsetReset

public java.lang.String getAutoOffsetReset()

setAutoOffsetReset

public void setAutoOffsetReset(java.lang.String autoOffsetReset)

isValidAutoOffsetReset

@AssertTrue(message="AutoOffset Reset can either be \'smallest\' or \'largest\'")
public boolean isValidAutoOffsetReset()