- 消费组组员，最多增加到和partition数量一致，超过的组员只会占用资源，而不起作用。
- kafka的partition的个数一定要大于消费组组员的个数，并且partition的个数对于消费组组员取模一定要为0，不然有些消费者会占用资源却不起作用。
3.如果需要增加消费组的组员个数，那么也需要根据上面的算法，调整partition的个数。
4、换更快的磁盘 ssd
-
信息被删除或无权限查看
- 如何缓解 Kafka 集群在有大量 topic 时性能快速劣化的问题？
- kafka topic 数据如何写入 hdfs？
- kafka 发布消息如何达到不重不漏？
- kafka 0.9 之后的版本如何获取 offset 用于计算出 lag 呢？
- kafka 如何减少消息时延？
- cdh 集群启用 kerberos 认证出现如下错误？
- yarn 提交任务之后一直处于 pending 状态怎么解决？
-
信息被删除或无权限查看
- Pandas 读取 Excel 中指定单元格后再取 dataFrame 怎么做?
- Python 的 for in 循环能嵌套使用？
- pygame 的图片为什么加载不出来？
-
信息被删除或无权限查看
- 有没有大佬知道，pygame 中 get_busy () 函数怎样才会返回一个 1？
- CDH 集群环境安全问题如何解决？