java - KafkaTemplate 和 KafkaProducer 发送方法的区别？

Question

我的问题是在使用kafka的Spring Boot微服务中什么适合使用KafkaTemplate.send()或KafkaProducer.send()

我使用 KafkaConsumer 而不是 KafkaListner 来轮询记录，因为 KafkaListner 会在记录进入主题时获取记录，我希望根据业务需求定期轮询记录。

已阅读KafkaProducer的文档https://kafka.apache.org/10/javadoc/org/apache/kafka/clients/producer/KafkaProducer.html

和Spring KafkaTemplate

https://docs.spring.io/spring-kafka/reference/html/#kafka-template

我无法做出决定，比如什么是理想的使用方式，或者至少使用其中一种而不是另一种的原因尚不清楚？

我的需要是我希望操作同步，即我想知道发布是否成功，因为如果记录未交付，我需要重试发布。

任何帮助将不胜感激。

Answer 1

对于你的第一个问题，我应该使用kafka模板还是Kafka生产者？

The Kafka Producer is defined in Apache Kafka. The KafkaTemplate is Spring's implementation of it (although it does not implement Producer directly) and so it provides more methods for you to use.

阅读此链接::

What is the difference between Kafka Template and kafka producer?

用于发布失败时的重试机制。 我在另一个问题里已经回答过这个问题了。

The acks parameter control how many partition replicas must receive the record before the producer can consider the write successful.

There are 3 values for the acks parameter:

acks=0, the producer will not wait for a reply from the broker before assuming the message sent successfully.

acks=1, the producer will receive a successful response from the broker the moment the leader replica received the message. If the message can't be written to the leader, the producer will receive an error response and can retry.

acks=all, the producer will receive a successful response from the broker once all in-sync replicas received the message.

Best way to configure retries in Kaka Producer