public class KafkaConsumerOptionsMixin
extends java.lang.Object
Constructor and Description |
---|
KafkaConsumerOptionsMixin() |
Modifier and Type | Method and Description |
---|---|
int |
getAutoCommitInterval() |
java.lang.String |
getAutoOffsetReset() |
int |
getConsumerTimeout() |
int |
getFetchMaxBytes() |
int |
getFetchMaxWait() |
int |
getFetchMinBytes() |
int |
getQueuedChunksMax() |
int |
getRebalanceBackoff() |
int |
getRebalanceMaxRetries() |
int |
getRefreshLeaderBackOff() |
int |
getSocketBufferBytes() |
int |
getSocketTimeout() |
boolean |
isAutoCommitEnable() |
boolean |
isValidAutoOffsetReset() |
void |
setAutoCommitEnable(boolean autoCommitEnable) |
void |
setAutoCommitInterval(int autoCommitInterval) |
void |
setAutoOffsetReset(java.lang.String autoOffsetReset) |
void |
setConsumerTimeout(int consumerTimeout) |
void |
setFetchMaxBytes(int fetchMaxBytes) |
void |
setFetchMaxWait(int fetchMaxWait) |
void |
setFetchMinBytes(int fetchMinBytes) |
void |
setQueuedChunksMax(int queuedChunksMax) |
void |
setRebalanceBackoff(int rebalanceBackoff) |
void |
setRebalanceMaxRetries(int rebalanceMaxRetries) |
void |
setRefreshLeaderBackOff(int refreshLeaderBackOff) |
void |
setSocketBufferBytes(int socketBufferBytes) |
void |
setSocketTimeout(int socketTimeout) |
public int getSocketTimeout()
public void setSocketTimeout(int socketTimeout)
public int getSocketBufferBytes()
public void setSocketBufferBytes(int socketBufferBytes)
public int getFetchMaxBytes()
public void setFetchMaxBytes(int fetchMaxBytes)
public boolean isAutoCommitEnable()
public void setAutoCommitEnable(boolean autoCommitEnable)
public int getAutoCommitInterval()
public void setAutoCommitInterval(int autoCommitInterval)
public int getQueuedChunksMax()
public void setQueuedChunksMax(int queuedChunksMax)
public int getRebalanceMaxRetries()
public void setRebalanceMaxRetries(int rebalanceMaxRetries)
public int getFetchMinBytes()
public void setFetchMinBytes(int fetchMinBytes)
public int getFetchMaxWait()
public void setFetchMaxWait(int fetchMaxWait)
public int getRebalanceBackoff()
public void setRebalanceBackoff(int rebalanceBackoff)
public int getRefreshLeaderBackOff()
public void setRefreshLeaderBackOff(int refreshLeaderBackOff)
public java.lang.String getAutoOffsetReset()
public void setAutoOffsetReset(java.lang.String autoOffsetReset)
@AssertTrue(message="AutoOffset Reset can either be \'smallest\' or \'largest\'") public boolean isValidAutoOffsetReset()
public int getConsumerTimeout()
public void setConsumerTimeout(int consumerTimeout)