Spring Kafka重试主题：配置让Kafka自动选重试/DLT分区遇启动问题

在Spring Kafka 2.7.12版本中，你遇到的启动报错是因为手动声明DeadLetterPublishingRecovererFactory Bean时，没有正确关联自动配置的DestinationTopicResolver。以下是正确的配置方式：

核心配置思路 #

不要手动声明DeadLetterPublishingRecovererFactory Bean，而是通过继承RetryTopicConfigurationSupport类来统一配置重试主题逻辑，这样Spring会自动初始化DestinationTopicResolver及包含重试主题信息的映射，同时你可以自定义分区解析规则。

完整配置示例 #

@Configuration
public class KafkaRetryConfig extends RetryTopicConfigurationSupport {

    // 自定义分区解析器：返回null让Kafka自动选择分区
    @Override
    protected void configureDeadLetterPublishingRecovererFactory(DeadLetterPublishingRecovererFactory factory) {
        factory.setDestinationPartitionResolver((consumerRecord, nextTopic) -> null);
    }

    // 配置重试主题、DLT及重试规则
    @Override
    protected RetryTopicConfigurationBuilder configureRetryTopics(RetryTopicConfigurationBuilder builder) {
        return builder
                .topic("你的主主题名称")
                .dltTopic("你的DLT主题名称")
                .retryTopicSuffix("-retry") // 重试主题命名后缀，可自定义
                .fixedBackOff(2000) // 重试间隔2秒
                .maxAttempts(3); // 最大重试次数
    }
}

关键说明 #

1. 分区选择逻辑：当DestinationPartitionResolver返回null时，Kafka Producer会使用默认分区策略（按消息key哈希或轮询），自动适配主主题、重试主题、DLT不同的分区数。
2. 自动配置关联：继承RetryTopicConfigurationSupport后，Spring会自动创建DestinationTopicResolver并注入重试主题的映射信息，无需手动处理。
3. 主题前置条件：确保你的主主题、重试主题、DLT已提前创建并设置好对应分区数（生产环境不依赖auto.create.topics.enable自动创建）。

内容的提问来源于stack exchange，提问作者Lorenzo Panetta