如何强制Spring Kafka不自动创建主题，仅使用预先创建好的主题

解决方案 #

1. 核心配置修正 #

你当前@RetryableTopic未指定自定义DLT主题名，框架默认生成{原主题}-dlt格式的主题名，和你预定义的my_dlt_topic不匹配，这是最主要的问题，按如下方式修改注解配置：

@KafkaListener(topics = ["#{config.messageBus.topic}"], groupId = "group_id")
@RetryableTopic(
    dltStrategy = DltStrategy.ALWAYS_RETRY_ON_ERROR,
    autoCreateTopics = "false",
    attempts = "1",
    dltTopic = "#{config.messageBus.dltTopic}", // 显式指定预创建的DLT主题名
    kafkaTemplateRef = "kafkaTemplate" // 绑定你自定义的KafkaTemplate（如果有特殊配置需要的话）
)
@Throws(IOException::class)
fun consume(rawMessage: String?) {
    // 业务消费逻辑
}

2. 移除多余逻辑 #

@RetryableTopic默认会自动将消费失败的消息投递到指定DLT主题，不需要你在@DltHandler中手动调用kafkaTemplate.send发送消息，如果你不需要对死信消息做额外的日志、统计等处理，可以直接删除@DltHandler方法；如果需要做自定义处理，仅保留业务逻辑即可：

@DltHandler
fun processMessage(rawMessage: String?) {
    // 仅保留你的自定义处理逻辑，比如日志记录、告警等，无需手动发送到DLT
    log.error("收到死信消息：{}", rawMessage)
}

3. 全局关闭自动创建主题 #

为了完全避免Spring Kafka尝试创建/校验主题，在application.yml中增加全局配置：

spring:
  kafka:
    admin:
      auto-create: false

4. 可选：确认依赖版本 #

如果你使用的Spring Kafka版本低于2.8.0，@RetryableTopic的部分参数行为存在差异，建议升级到2.8.x及以上稳定版本使用该注解。

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