Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_PORT |
9092 |
Modifier and Type | Constant Field | Value |
---|---|---|
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 |
Modifier and Type | Constant Field | Value |
---|---|---|
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" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_WAIT_FOR_LEADER_REFRESH_RETRY |
5000 |
Modifier and Type | Constant Field | Value |
---|---|---|
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" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
ACKNOWLEDGMENT |
"kafka_acknowledgment" |
public static final java.lang.String |
MESSAGE_KEY |
"kafka_messageKey" |
public static final java.lang.String |
NEXT_OFFSET |
"kafka_nextOffset" |
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" |
Modifier and Type | Constant Field | Value |
---|---|---|
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 |