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.listener.KafkaTopicOffsetManager
public static final java.lang.String CLEANUP_POLICY "cleanup.policy"
public static final java.lang.String CLEANUP_POLICY_COMPACT "compact"
public static final java.lang.String DELETE_RETENTION "delete.retention.ms"
public static final java.lang.String SEGMENT_BYTES "segment.bytes"

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"

org.springframework.integration.kafka.util.TopicUtils
public static final int METADATA_VERIFICATION_MAX_INTERVAL 1000
public static final int METADATA_VERIFICATION_RETRY_ATTEMPTS 10
public static final double METADATA_VERIFICATION_RETRY_BACKOFF_MULTIPLIER 1.5
public static final int METADATA_VERIFICATION_RETRY_INITIAL_INTERVAL 100
public static final int METADATA_VERIFICATION_TIMEOUT 5000


Spring Integration Kafka Support