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

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

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

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

标签： javaspringspring-bootspring-cloud-streamspring-cloud-stream-binder-kafka

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

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