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

Question

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

Answer 1

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

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