Describe: kafka simple producer/consumer
From: frank.zhao kafka-client
Dependency: kafka version: 0.10.0.1, jdk1.8
com.simple.kafka.consumer.KafkaConsumer 消费者
sample:
'new KafkaConsumer<String, String>(props).build().consumer("test", 3 , s -> doSomething(s));'
com.simple.kafka.producer.KafkaProducer 生产者
sample:
'KafkaProducer<String, String> producer = new KafkaProducer<>(props).build();'
'while (true) {
producer.sendMsg("test", UUID.randomUUID().toString(), (metadata, exception)
-> callBack()
}'
or:
self implements `ProducerCallBack`