public static final java.lang.String |
clientId |
"SimpleConsumerDemoClient" |
public static final int |
connectionTimeOut |
100000 |
public static final java.lang.String |
groupId |
"group1" |
public static final int |
kafkaProducerBufferSize |
65536 |
public static final int |
kafkaServerPort |
9092 |
public static final java.lang.String |
kafkaServerURL |
"localhost" |
public static final int |
reconnectInterval |
10000 |
public static final java.lang.String |
topic |
"topic1" |
public static final java.lang.String |
topic2 |
"topic2" |
public static final java.lang.String |
topic3 |
"topic3" |
public static final java.lang.String |
zkConnect |
"127.0.0.1:2181" |