如何在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標誌。