使用spring cloud stream kafka读取消息的编程方式

【问题标题】：Programmatic way to read message using spring cloud stream kafka使用spring cloud stream kafka读取消息的编程方式
【发布时间】：2020-12-25 23:35:17
【问题描述】：

我有一个与之相关的主题和 DLQ。我正在使用@StreamListener 作为主题。我想使用控制器端点按需读取/处理来自 DLQ 的消息。

是否可以使用 Spring Cloud Stream Kafka 来做到这一点。

我们没有在生产中使用执行器。所以不能使用 /bindings 端点。

【问题讨论】：

标签： java spring spring-boot spring-cloud-stream spring-cloud-stream-binder-kafka

【解决方案1】：

您不需要通过 web 启用执行器，但您需要将执行器启动器添加到类路径；那么你可以在这个问题的答案中使用该技术：Stop consume message for Stream listener

正如那里的 cmets 所述，将功能与执行器分开存在一个未解决的问题。

【讨论】：