Kafka暂停消费--consumer.pause()
Posted
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Kafka暂停消费--consumer.pause()相关的知识，希望对你有一定的参考价值。
参考技术A 遇到了需要暂停消费的场景，使用pause()方法暂停消费，resume()方法恢复消费，基于springboot的demo如下:assign 和 subscribe 的区别 ：assign方法由用户直接手动consumer实例消费哪些具体分区，assign的consumer不会拥有kafka的group management机制，也就是当group内消费者数量变化的时候不会有reblance行为发生。assign的方法不能和subscribe方法同时使用。
通过switchOn变量来手动的控制暂停跟恢复
以上是关于Kafka暂停消费--consumer.pause()的主要内容，如果未能解决你的问题，请参考以下文章
即使我暂停消费者，Spring Kafka 也总是在 5 分钟后重新平衡