public class KafkaConsumerProducerDemo extends java.lang.Object implements KafkaProperties
clientId, connectionTimeOut, groupId, kafkaProducerBufferSize, kafkaServerPort, kafkaServerURL, reconnectInterval, topic, topic2, topic3, zkConnect
Constructor and Description |
---|
KafkaConsumerProducerDemo() |
Modifier and Type | Method and Description |
---|---|
static void |
main(java.lang.String[] args) |