Spring Integration Kafka Support

org.springframework.integration.kafka.core
Class KafkaConsumerDefaults

java.lang.Object
  extended by 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

Field Summary
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 Summary
KafkaConsumerDefaults()
           
 
Method Summary
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

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
Constructor Detail

KafkaConsumerDefaults

public KafkaConsumerDefaults()

Spring Integration Kafka Support