spring-integration - Spring Cloud Data Flow中如何配置Kafka绑定死信队列

Question

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

任何人都可以帮助我或指向文档以了解更多信息吗？

Answer 1

这里解释了 Kafka 消费者和支持的覆盖。您必须专门打开enableDlq布尔标志。

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

数据流：> 流创建 foo --definition "http | log"

数据流：> 流部署 foo --properties “app.http.spring.cloud.stream.bindings.output.destination=test,app.log.spring.cloud.stream.bindings.input.destination=test,app.log。 spring.cloud.stream.kafka.bindings.test.consumer.enableDlq=true"

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