我注意到有几个制片人在那里：
org.apache.kafka.clients.producer.KafkaProducer<K,V> kafka.javaapi.producer.Producer
他们之间有什么区别？应该使用哪一种？为什么？请建议！
db2dz4w81#
kafka.javaapi.producer.Producer 是kafka 0.8.x中使用的旧的遗留生产者这是在scala中实现的，但是有一个专用的JavaAPI。在普通的Kafka艺术品中仍然可以找到。 org.apache.kafka.clients.producer.KafkaProducer 新的producer实现是用java编写的，与旧版本相比有很多改进，应该与kafka 0.9.0.0版本一起使用。这在单独的客户端依赖关系中可用，坐标为： <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>0.9.0.0</version> </dependency>
kafka.javaapi.producer.Producer
org.apache.kafka.clients.producer.KafkaProducer
<dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>0.9.0.0</version> </dependency>
1条答案
按热度按时间db2dz4w81#
kafka.javaapi.producer.Producer是kafka 0.8.x中使用的旧的遗留生产者这是在scala中实现的，但是有一个专用的JavaAPI。在普通的Kafka艺术品中仍然可以找到。org.apache.kafka.clients.producer.KafkaProducer新的producer实现是用java编写的，与旧版本相比有很多改进，应该与kafka 0.9.0.0版本一起使用。这在单独的客户端依赖关系中可用，坐标为：<dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>0.9.0.0</version> </dependency>