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

Question

DeadLetterPublishingRecoverer是否需要单独的KafkaTemplate？

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

Answer 1

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