org.springframework.integration.kafka.core
Class KafkaConsumerDefaults
java.lang.Object
org.springframework.integration.kafka.core.KafkaConsumerDefaults
public abstract class KafkaConsumerDefaults
- extends java.lang.Object
Kafka adapter specific message headers.
- Since:
- 0.5
- Author:
- Soby Chacko, Marius Bogoevici
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
GROUP_ID
public static final java.lang.String GROUP_ID
- See Also:
- Constant Field Values
SOCKET_TIMEOUT_INT
public static final int SOCKET_TIMEOUT_INT
- See Also:
- Constant Field Values
SOCKET_TIMEOUT
public static final java.lang.String SOCKET_TIMEOUT
SOCKET_BUFFER_SIZE_INT
public static final int SOCKET_BUFFER_SIZE_INT
- See Also:
- Constant Field Values
SOCKET_BUFFER_SIZE
public static final java.lang.String SOCKET_BUFFER_SIZE
FETCH_SIZE_INT
public static final int FETCH_SIZE_INT
- See Also:
- Constant Field Values
FETCH_SIZE
public static final java.lang.String FETCH_SIZE
BACKOFF_INCREMENT
public static final java.lang.String BACKOFF_INCREMENT
- See Also:
- Constant Field Values
QUEUED_CHUNKS_MAX
public static final java.lang.String QUEUED_CHUNKS_MAX
- See Also:
- Constant Field Values
AUTO_COMMIT_ENABLE
public static final java.lang.String AUTO_COMMIT_ENABLE
- See Also:
- Constant Field Values
AUTO_COMMIT_INTERVAL
public static final java.lang.String AUTO_COMMIT_INTERVAL
- See Also:
- Constant Field Values
AUTO_OFFSET_RESET
public static final java.lang.String AUTO_OFFSET_RESET
- See Also:
- Constant Field Values
CONSUMER_TIMEOUT
public static final java.lang.String CONSUMER_TIMEOUT
- See Also:
- Constant Field Values
REBALANCE_RETRIES_MAX
public static final java.lang.String REBALANCE_RETRIES_MAX
- See Also:
- Constant Field Values
MIN_FETCH_BYTES
public static final int MIN_FETCH_BYTES
- See Also:
- Constant Field Values
MAX_WAIT_TIME_IN_MS
public static final int MAX_WAIT_TIME_IN_MS
- See Also:
- Constant Field Values
DEFAULT_OFFSET_RESET
public static final long DEFAULT_OFFSET_RESET
FETCH_METADATA_TIMEOUT
public static final int FETCH_METADATA_TIMEOUT
- See Also:
- Constant Field Values
KafkaConsumerDefaults
public KafkaConsumerDefaults()