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