【思考？】什么时候会触发这个策略呢？

当出现以下几种情况时，kafka会进行一次分区分配操作，也就是kafka consumer的rebalance

1. 同一个consumer group内新增了消费者

2. 消费者离开当前所属的consumer group，比如主动停机或者宕机

3. topic新增了分区（也就是分区数量发生了变化）

kafka consuemr的rebalance机制规定了一个consumer group下的所有consumer如何达成一致来分配订阅topic的每个分区。而具体如何执行分区策略，就是前面提到过的两种内置的分区策略。而kafka对于分配策略这块，提供了可插拔的实现方式，也就是说，除了这两种之外，我们还可以创建自己的分配机制。

【思考？】什么时候会触发这个策略呢？相关推荐

什么时候会触发这个策略呢？
当出现以下几种情况时,kafka会进行一次分区分配操作,也就是kafka consumer的rebalance 1. 同一个consumer group内新增了消费者 2. 消费者离开当前所属的con ...
制定备份策略的指导方向思考
摘自一本很不错的书,哇塞,精华绝对的,我要记录下来,吼吼...大师思考的就是全面制定备份策略 (客户资源配置充配.存储空间充足) 1.备份的数据库还有可能恢复么? 2.最早希望恢复到什么时间点? 3 ...
全面了解风控策略体系
模型和策略的开发是一个系统工程,这其中需要有业务经验.统计理论.算法运用.和数据认知,是一个不断反思,不断积累经验的过程.沙滩上建不起摩天大楼.扎扎实实的基本功永远有价值,永远不会过时. --余旭鑫博 ...
击穿线程池面试题：3大方法，7大参数，4种拒绝策略
前言:多线程知识是Java面试中必考的点.本文详细介绍--线程池.在实际开发过程里,很多IT从业者使用率不高,也只是了解个理论知识,和背诵各种八股文,没有深入理解到脑海里,导致面试完就忘.--码农 = ...
浅谈语音助手的对话管理与策略制定
本篇文章首先梳理了对话系统中的对话管理的原理,包括中控系统的分发.各类bot处理Query的逻辑.候选回复融合和排序的功能,其中也包含了垂直领域知识图谱的构建.最后从PM角度思考,为了提升bot的表现 ...
面试必问---Java线程池8大拒绝策略
前言谈到java的线程池最熟悉的莫过于ExecutorService接口了,jdk1.5新增的java.util.concurrent包下的这个api,大大的简化了多线程代码的开发.而不论你用Fix ...
面试官问：线程池除了常见的4种拒绝策略，你还知道哪些？
点击关注上方"视学算法",设为"置顶或星标" 第一时间送达技术干货. 来源 | http://rrd.me/en3Wp 前言谈到java的线程池最熟悉的莫过于 ...
Java 线程池必知的8 大拒绝策略
点击上方蓝色"程序猿DD",选择"设为星标" 回复"资源"获取独家整理的学习资料! 来源 | kailing.pub/article/ind ...
ThreadPoolExecutor 的八种拒绝策略 | 含番外！
点击蓝色"程序猿DD"关注我回复"资源"获取独家整理的学习资料! 作者 | KL 来源 | http://rrd.me/en3Wp 前言谈到java的线程池 ...

【思考？】什么时候会触发这个策略呢？

【思考？】什么时候会触发这个策略呢？相关推荐

最新文章

热门文章