我有一个与之相关的主题和 DLQ。我正在使用@StreamListener 作为主题。我想使用控制器端点按需读取/处理来自 DLQ 的消息。
是否可以使用 Spring Cloud Stream Kafka 来做到这一点。
我们没有在生产中使用执行器。所以不能使用 /bindings 端点。
1 回答
1
您不需要通过 web 启用执行器，但您需要将执行器启动器添加到类路径；那么你可以在这个问题的答案中使用该技术：Stop consume message for Stream listener
如那里的评论中所述，将功能与执行器分开存在一个未解决的问题。
于 2020-09-07T17:33:25.430 回答