如何在需要时打开和关闭kafka读取消息

发布于 2025-01-10 08:27:55 字数 86 浏览 0 评论 0原文

我有一个从 kafka 读取消息的 spring 应用程序,我希望当我启用维护时,我的应用程序将不再从 kafka 读取消息,当我关闭维护时,它将恢复正常读取

I have a spring application that reads messages from kafka, I want when I enable maintenance my application will not read messages from kafka anymore and when I turn off maintenance it will return to normal reading

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

评论(1

櫻之舞 2025-01-17 08:27:55

我们可以在KafkaListener上调用pause()/resume()。请参阅

https://docs.spring.io/spring-kafka/参考/html/#pause-resume

We can invoke the pause( )/resume( ) on the KafkaListener. Refer

https://docs.spring.io/spring-kafka/reference/html/#pause-resume

~没有更多了~
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文