我正在寻找一种解决方案，以便在下游服务关闭时暂停来自应用程序本身的 kinesis 流的消息消耗。我正在使用弹簧-云-溪流-粘合剂-运动。没有明显的选择可以做到这一点。KCL api 上似乎也没有选项。弹簧致动器绑定端点上有停止/暂停，这似乎不适用于 Kinesis。一种选择是使用 AWS 开发工具包 API 并执行拉取而不是 KCL/Spring 云的推送机制，并停止拉取断路器。
还有其他选择吗？
Kinesis 使用者(独立于库(根本不支持pause/resume。AWS Kinesis 中没有这样的概念。
您确实可以使用start/stop执行器端点进行特定绑定，以控制其生命周期。
不知道你为什么说它不起作用：这部分与其他粘合剂没有区别。