Лучшего Кафка Производитель

Question

Я заметил, что есть несколько производителей наша там:

org.apache.kafka.clients.producer.KafkaProducer<K,V> 

kafka.javaapi.producer.Producer 

В чем разница между ними? Какой из них следует использовать и почему? Пожалуйста, предложите!

Answer 1

kafka.javaapi.producer.Producer является старым продюсером, который использовался в Kafka 0.8.x. Это было реализовано в Scala, но имеет специальный Java API. Он по-прежнему доступен в общем артефакте Кафки.

org.apache.kafka.clients.producer.KafkaProducer - это новая реализация производителя, написанная на Java, имеет множество улучшений по сравнению со старым и является той, которую вы должны использовать с версией Kafka 0.9.0.0. Это доступно в отдельной зависимости клиента с координатами:

<dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>0.9.0.0</version> </dependency>