Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
CLIENT_ID |
"SimpleConsumerDemoClient" |
public static final int |
CONNECTION_TIMEOUT |
100000 |
public static final int |
KAFKA_PRODUCER_BUFFER_SIZE |
65536 |
public static final int |
KAFKA_SERVER_PORT |
9092 |
public static final java.lang.String |
KAFKA_SERVER_URL |
"localhost" |
public static final java.lang.String |
TOPIC |
"topic1" |
public static final java.lang.String |
TOPIC2 |
"topic2" |
public static final java.lang.String |
TOPIC3 |
"topic3" |