public abstract class KafkaConsumerDefaults
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
AUTO_COMMIT_ENABLE |
static java.lang.String |
AUTO_COMMIT_INTERVAL |
static java.lang.String |
AUTO_OFFSET_RESET |
static java.lang.String |
BACKOFF_INCREMENT |
static java.lang.String |
CONSUMER_TIMEOUT |
static long |
DEFAULT_OFFSET_RESET |
static int |
FETCH_METADATA_TIMEOUT |
static java.lang.String |
FETCH_SIZE |
static int |
FETCH_SIZE_INT |
static java.lang.String |
GROUP_ID |
static int |
MAX_WAIT_TIME_IN_MS |
static int |
MIN_FETCH_BYTES |
static java.lang.String |
QUEUED_CHUNKS_MAX |
static java.lang.String |
REBALANCE_RETRIES_MAX |
static java.lang.String |
SOCKET_BUFFER_SIZE |
static int |
SOCKET_BUFFER_SIZE_INT |
static java.lang.String |
SOCKET_TIMEOUT |
static int |
SOCKET_TIMEOUT_INT |
Constructor and Description |
---|
KafkaConsumerDefaults() |
public static final java.lang.String GROUP_ID
public static final int SOCKET_TIMEOUT_INT
public static final java.lang.String SOCKET_TIMEOUT
public static final int SOCKET_BUFFER_SIZE_INT
public static final java.lang.String SOCKET_BUFFER_SIZE
public static final int FETCH_SIZE_INT
public static final java.lang.String FETCH_SIZE
public static final java.lang.String BACKOFF_INCREMENT
public static final java.lang.String QUEUED_CHUNKS_MAX
public static final java.lang.String AUTO_COMMIT_ENABLE
public static final java.lang.String AUTO_COMMIT_INTERVAL
public static final java.lang.String AUTO_OFFSET_RESET
public static final java.lang.String CONSUMER_TIMEOUT
public static final java.lang.String REBALANCE_RETRIES_MAX
public static final int MIN_FETCH_BYTES
public static final int MAX_WAIT_TIME_IN_MS
public static final long DEFAULT_OFFSET_RESET
public static final int FETCH_METADATA_TIMEOUT