暂停弹簧云流kafka粘合剂编程



i在Spring Boot应用程序上工作,该应用程序使用Spring Cloud Stream与Kafka集成。

我需要以编程方式暂停从Kafka接收消息。我可以说有可能通过执行器端点(文档(管理绑定生命周期的可能性。因此,我可以自动使用org.springframework.cloud.stream.endpoint.BindingsEndpoint并使用其公共方法。但在我看来,这一点奇怪...

有没有更好地管理绑定生命周期的方法?

可以在您自己的代码中使用该 BindingsEndpoint bean。目的实际上是管理绑定的生命周期。该豆子只有一个简单的奖励,它被暴露为执行器端点,以管理静止的绑定。

否则,您将走复制/粘贴BindingsEndpoint ...

的逻辑

最新更新