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