|
|||||||||
PREV NEXT | FRAMES NO FRAMES |
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 |
|
|||||||||
PREV NEXT | FRAMES NO FRAMES |