KafkaTemplate 用于 Spring-Kafka 中的死信处理程序

Question

DeadLetterPublishingRecoverer 需要单独的 KafkaTemplate 吗？

我有一个用于向 Kafka 发送消息的 KafkaTemplate，然后我有一个带有 SeekToCurrentErrorHandler 和 DeadLetterPublishingRecoverer 的 KafkaListenerContainerFactory，这反过来又要求我提供一个 KafkaTempate。我真的需要这个另一个模板来处理 dlq 还是应该将这个 KafkaTemplate 用于我的正常 kafka 操作？我想我也可以对两者都使用非通用的 KafkaTemplate，但我怀疑这远非最佳实践。

Answer 1

如果泛型类型不同，你可以配置2个模板，或者使用<Object, Object>（只要你的序列化器可以处理这两种类型）。