异常没有嵌入 DLQ

Question

我已经用 kafka binder 设置了一个 spring 云流。我还启用了 DLQ 并设置了 headerMode 以捕获异常消息，如 here 所述。但是，当出现异常时，我只在我的 kafka 主题中看到消息，没有异常详细信息。我的 application.yml 看起来像这样

spring:
  application:
    name: Sample Stream
  cloud:
    stream:
      defaultBinder: kafka
      default:
        consumer:
          headerMode: raw
        producer:
          headerMode: raw
      kafka:
        binder:
          zkNodes: zookeeper
          brokers: kafka
        bindings:
          input:
            consumer:
              enableDlq: true
              dlqName: testDLQ

我正在使用 spring-cloud-starter-stream-kafka 的 1.2.1.RELEASE 版本

Answer 1

Kafka（0.11 之前）不支持标头；可以增强 kafka11 binder（1.3.x、2.0.x）以在标头中包含此类信息（类似于 rabbit binder repulishToDlq 选项。

如果你想关注它，我只是opened an issue for this。