如何在Spring Cloud数据流中配置Kafka绑定的死信队列

Question

在Spring Cloud Dataflow文档中，有一些提到的“死信队列”，它可用于消息处理中的异常。但是我没有在这方面找到进一步的地方。 我正在尝试在我的处理管道中配置一个Kafka绑定的死信队列。

任何人都可以帮助我或指向文档来了解更多关于此？

Answer 1

卡夫卡消费者和支持的覆盖被解释为here。你必须特别打开enableDlq布尔标志。

在您的流定义中，在消费者应用程序级别，您可以选择配置DLQ并在流部署时提供必要的属性。

数据流：>流生成foo --definition “HTTP |日志”

数据流：>流部署富--properties“app.http.spring.cloud.stream.bindings.output.destination =测试，app.log.spring.cloud.stream.bindings.input.destination =测试，app.log.spring.cloud.stream.kafka.bindings.test.consumer.enableDlq =真正的”

在这里，我们明确地覆盖channelName为“测试”，因此我们可以在消费者（log）应用程序中使用它并启用DLQ标志。