Spring Cloud Kafka Stream - 不同集群中的死信主题

Question

我有一个 Kafka 消费者。如果消费者未能阅读任何消息，我需要将其发送到死信主题。我正在使用 Spring cloud Kafka 流，我在这样的配置中启用了 DLQ。

spring:
  cloud:
    stream:
      function:
        definition: myConsumer
      kafka:
        binder:
          consumer-properties:
            auto.offset.reset: earliest
        bindings:
           myConsumer-in-0:
            consumer:
              **enableDlq: true
              dlqName: api-consumer-count-request-DLT** ( this is in different cluster, this has its own broker list.)
      bindings:
        myConsumer-in-0:
          binder: myBinder
          destination: api-consumer
          group: count-execution
      binders:
      myBinder:
          type: kafka
          environment:
            spring:
              cloud:
                stream:
                  kafka:
                    binder:
                      brokers:{regular broker list for consumer}

但我的常规消费者主题与 DLQ 主题位于不同的集群中。有可能实现这一目标吗？如果是，您能指导我完成配置吗？

Answer 1

没有；目前这是不可能的； binder 只会发布到同一个 Kafka 集群。