如何配置 2 个侦听同一主题的 Spring Kafka 侦听器，使其具有自己的重试和死信主题

问：

在 Spring Kafka 中，我有两个 Kafka 听众在听同一个主题。我希望两个侦听器都有自己的重试和死信主题，因此如果一个侦听器发生故障，它不会重播给另一个侦听器。使用以下配置，它们最终都将使用相同的重试和死信主题

• payment-topic
• payment-topic-重试
• payment-topic-dlt

class PaymentListener {
    
    @KafkaListener(topics = ["payment-topic"],)
    fun sendBill(payment: Payment) {
        // ...some logic
    }

    @KafkaListener(topics = ["payment-topic"],)
    fun adjustBalance(payment: Payment) {
        // ...some logic
    }
}

    @Bean
    fun paymentTopicRetryStrategy(
        template: KafkaTemplate<String, ClearingFinishedEvent>,
    ): RetryTopicConfiguration {
        return RetryTopicConfigurationBuilder
            .newInstance()
            .useSingleTopicForSameIntervals()
            .fixedBackOff(3000)
            .maxAttempts(3)
            .includeTopic("payment-topic")
            .dltProcessingFailureStrategy(DltStrategy.ALWAYS_RETRY_ON_ERROR)
            .autoCreateTopics(true, 1, BROKER_DEFAULT)
            .create(template)
    }

我真正想要的是：

• payment-topic

[sendBill 侦听器将这些用作重试和死信主题]

• 发送账单支付主题重试
• 发送账单支付主题DLT

[adjustBalance 监听器使用这些作为重试和死信主题]

• 调整余额支付主题重试
• adjust-balance-payment-topic-dlt

我可以编写一个自定义命名策略 （https://docs.spring.io/spring-kafka/docs/current/reference/html/#custom-naming-strategies），但我无法获得侦听器的详细信息，因此我无法使其足够具体。

有什么想法吗？