-
Kafka客户端依赖包以及示例代码
资源介绍
版本：kafka_2.12-0.10.2.1，生产者消费者示例代码，以及client相关包。
部分代码：
public static KafkaProducer getProducer() {
if (kp == null) {
Properties props = new Properties();
props.put("bootstrap.servers", "127.0.0.1:9092");
props.put("acks", "0");
props.put("retries", 0);
props.put("batch.size", 16384);
props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
kp = new KafkaProducer(props);
}
return kp;
}
- 上一篇: kafka生产者消费者实例
- 下一篇: kafka-2.10-0.8.2.2.jar