如何暂停消费者在 spring 云运动流中消费消息
How to pause consumers from consuming messages in spring cloud kinesis stream
我正在寻找一种解决方案，以在下游服务关闭时暂停从应用程序本身的运动流中消耗消息。我正在使用 spring-cloud-stream-binder-kinesis。没有明显的选择可以做到这一点。 KCL api 上似乎没有选项，因为 well.There 是 spring 执行器绑定端点上的 stop/pause，这似乎不适用于 Kinesis。一种选择是使用 AWS SDK api 并执行拉取而不是 KCL/Spring 云的推送机制并停止拉取断路器。
还有其他选择吗？
Kinesis 消费者（独立于库）根本不支持 pause/resume。 AWS Kinesis 中没有这样的概念。
您确实可以使用 start/stop 执行器端点进行特定绑定以控制其生命周期。
不知道为什么说不行：这部分和其他活页夹没什么区别
我正在寻找一种解决方案，以在下游服务关闭时暂停从应用程序本身的运动流中消耗消息。我正在使用 spring-cloud-stream-binder-kinesis。没有明显的选择可以做到这一点。 KCL api 上似乎没有选项，因为 well.There 是 spring 执行器绑定端点上的 stop/pause，这似乎不适用于 Kinesis。一种选择是使用 AWS SDK api 并执行拉取而不是 KCL/Spring 云的推送机制并停止拉取断路器。
还有其他选择吗？
Kinesis 消费者（独立于库）根本不支持 pause/resume。 AWS Kinesis 中没有这样的概念。
您确实可以使用 start/stop 执行器端点进行特定绑定以控制其生命周期。
不知道为什么说不行：这部分和其他活页夹没什么区别