public class KafkaConsumerOptionsMixin
extends java.lang.Object
Constructor and Description |
---|
KafkaConsumerOptionsMixin() |
Modifier and Type | Method and Description |
---|---|
AutoOffsetResetStrategy |
getAutoOffsetReset() |
long |
getAutoOffsetResetValue() |
int |
getFetchMaxBytes() |
int |
getFetchMaxWait() |
int |
getFetchMinBytes() |
int |
getSocketBufferBytes() |
int |
getSocketTimeout() |
void |
setAutoOffsetReset(AutoOffsetResetStrategy autoOffsetReset) |
void |
setFetchMaxBytes(int fetchMaxBytes) |
void |
setFetchMaxWait(int fetchMaxWait) |
void |
setFetchMinBytes(int fetchMinBytes) |
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 int getFetchMinBytes()
public void setFetchMinBytes(int fetchMinBytes)
public int getFetchMaxWait()
public void setFetchMaxWait(int fetchMaxWait)
@NotNull(message="AutoOffset Reset must either be \'smallest\' or \'largest\'") public AutoOffsetResetStrategy getAutoOffsetReset()
public void setAutoOffsetReset(AutoOffsetResetStrategy autoOffsetReset)
public long getAutoOffsetResetValue()