如何在需要时打开和关闭kafka读取消息
我有一个从 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 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论
评论(1)
我们可以在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