spring-kafka - 每个主题都需要一个 KafkaTemplate 吗？

Question

看起来可以使用泛型配置 KakfkaTemplate 来指示键和值。密钥类型是否特定于用例？例如一些识别信息，如 personId、patientId，该值将呈现某种 pojo（DTO，可能不是整个 JPA 实体）

这就引出了一个问题，我们是否应该根据用例（针对每个主题）配置多个 KafkaTemplate？

Answer 1

KakfkaTemplate为了编码方便，这是通用的。但是，如果您的不同主题处理不同的数据类型，那么您真的应该考虑KakfkaTemplate为此目的使用单独的类型安全。

另一个注意事项： KakfkaTemplate完全基于KafkaProducer，这需要特别ProducerProperties包括key/value序列化程序。

所以，是的，对于不同的数据类型，您需要单独KafkaProducer的 s ，因此，KakfkaTemplate. 即使他们调查同一个 Kafka Broker。