Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_DELAY_IN_SECONDS |
1 |
public static final int |
DEFAULT_RETRY_COUNT |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
ALL |
-1 |
public static final int |
DEFAULT |
-2147483648 |
public static final int |
NONE |
0 |
public static final int |
ONE |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_BOOTSTRAP_SERVERS |
"localhost:9092" |
public static final int |
DEFAULT_KAFKA_PORT |
9092 |
public static final java.lang.String |
EMBEDDED_TOPICS |
"kafka.embedded.topics" |
public static final java.lang.String |
PREFIX |
"kafka" |
public static final java.lang.String |
TOPICS |
"kafka.topics" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
PREFIX |
"kafka.consumers" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_HEALTHTIMEOUT |
10 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
PREFIX |
"kafka.producers" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
CLIENT_ID_TAG |
"client-id" |
public static final java.lang.String |
NODE_ID_TAG |
"node-id" |
public static final java.lang.String |
TOPIC_TAG |
"topic" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
PARTITION_TAG |
"partition" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
PREFIX |
"kafka.streams" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
ENABLED_PROPERTY |
"kafka.health.streams.enabled" |