问编程暂停Spring Cloud Stream Kafka绑定器
EN

Stack Overflow用户

提问于 2019-05-08 16:55:47

回答 1查看 362关注 0票数 1

我的工作是Spring Boot应用程序，它使用Spring Cloud Stream与Kafka集成。

我需要以编程方式暂停接收来自Kafka的消息。我知道如何通过执行器端点(docs)管理绑定的生命周期。这样我就可以自动连接org.springframework.cloud.stream.endpoint.BindingsEndpoint并使用它的公共方法。但对我来说似乎有点奇怪。

有没有更好的方法来以编程方式管理绑定的生命周期？

回答已采纳

发布于 2019-05-08 21:54:05

在您自己代码中使用BindingsEndpoint bean是可以的。它的目的实际上是管理绑定的生命周期。该bean只有一个简单的好处，即它被公开为一个执行器端点，用于管理REST上的绑定。

否则你就会去复制/粘贴BindingsEndpoint的逻辑...

票数 0

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/56036990

复制

相似问题

问编程暂停Spring Cloud Stream Kafka绑定器EN