当前位置: 首页 > 知识库问答 >
问题:

以编程方式暂停Spring Cloud Stream Kafka活页夹

曾弘扬
2023-03-14

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

我需要以编程方式暂停接收来自Kafka的消息。我知道通过执行器endpoint(文档)管理绑定生命周期的可能性。所以我可以自动装配org.springframework.cloud.stream.endpoint.BindingsEndpoint并使用它的公共方法。但在我看来有点奇怪...

是否有更好的方法以编程方式管理绑定的生命周期?

共有1个答案

艾茂学
2023-03-14

可以在您自己的代码中使用这个绑定发送点bean。它的目的实际上是管理绑定的生命周期。该bean有一个简单的好处,即它作为执行器endpoint公开,以管理REST上的绑定。

否则,您将复制/粘贴BindingsEndpoint的逻辑。。。

 类似资料:
  • 问题内容: 我正在开发一个Twitter应用程序,该应用程序直接从Twitter引用图像。如何防止动画gif播放? 在页面末尾使用不适用于Firefox。 是否有更好的JavaScript技巧?最好对所有浏览器都适用 问题答案: 这不是跨浏览器的解决方案,但是可以在Firefox和Opera中使用(不适用于ie8:-/)。采取从这里

  • 问题内容: 是否可以通过命令在任何行停止执行python脚本? 喜欢 问题答案: sys.exit()可以完全满足您的要求。

  • 下面是振动方法调用:

  • 暂停脚本的当前线程。 #p::Pause ; 按一次 Win+P 会暂停脚本. 再按一次则取消暂停. Pause [, On|Off|Toggle, OperateOnUnderlyingThread?] 参数 On|Off|Toggle 如果为空或省略, 则它默认为 Toggle. 否则, 请指定下列单词的其中一个: Toggle:如果在当前线程下的潜在线程处于运行状态,则暂停当前线程,否则让潜

  • 我们的生产服务器(apache-tomcat-7.0.6)出现了这个问题,它正在运行一个使用MySQL作为DB的Spring JPA Hibernate应用程序。在这个问题中,服务器速度变慢,一分钟内就会失去响应,活动的tomcat线程数达到200个(我们使用javamelody观察这些情况)。日志看起来像: 事务的创建一直持续到服务器达到200个线程(需要1-2分钟)并没有响应为止。在此期间,我

  • 本文向大家介绍C#程序暂停线程,包括了C#程序暂停线程的使用技巧和注意事项,需要的朋友参考一下 要在C#中暂停线程,请使用方法。 您需要设置线程要暂停的毫秒数,例如5秒钟,请使用- 示例 让我们看看如何循环并设置sleep方法来暂停线程。 输出结果