Spring Integration Kafka Support

Constant Field Values


Contents
org.springframework.*

org.springframework.integration.kafka.core.BrokerAddress
public static final int DEFAULT_PORT 9092

org.springframework.integration.kafka.core.KafkaConsumerDefaults
public static final java.lang.String AUTO_COMMIT_ENABLE "true"
public static final java.lang.String AUTO_COMMIT_INTERVAL "10000"
public static final java.lang.String AUTO_OFFSET_RESET "smallest"
public static final java.lang.String BACKOFF_INCREMENT "1000"
public static final java.lang.String CONSUMER_TIMEOUT "5000"
public static final int FETCH_METADATA_TIMEOUT 10000
public static final int FETCH_SIZE_INT 307200
public static final java.lang.String GROUP_ID "groupid"
public static final int MAX_WAIT_TIME_IN_MS 100
public static final int MIN_FETCH_BYTES 1
public static final java.lang.String QUEUED_CHUNKS_MAX "100"
public static final java.lang.String REBALANCE_RETRIES_MAX "4"
public static final int SOCKET_BUFFER_SIZE_INT 65536
public static final int SOCKET_TIMEOUT_INT 30000

org.springframework.integration.kafka.core.ZookeeperConnectDefaults
public static final java.lang.String ZK_CONNECT "localhost:2181"
public static final java.lang.String ZK_CONNECTION_TIMEOUT "6000"
public static final java.lang.String ZK_SESSION_TIMEOUT "6000"
public static final java.lang.String ZK_SYNC_TIME "2000"

org.springframework.integration.kafka.support.KafkaHeaders
public static final java.lang.String MESSAGE_KEY "kafka_messageKey"
public static final java.lang.String OFFSET "kafka__offset"
public static final java.lang.String PARTITION_ID "kafka__partitionId"
public static final java.lang.String TOPIC "kafka_topic"


Spring Integration Kafka Support