Consumer消费Parition的分配策略

参考答案

Kafka 提供的两种分配策略: range roundrobin ,由参数 partition.assignment.strategy 指定,默认是 range 策略。

当以下事件发生时,Kafka 将会进行一次分区分配:

  • 同一个 Consumer Group 内新增消费者。
  • 消费者离开当前所属的Consumer Group,包括shuts down 或 crashes。
  • 订阅的主题新增分区。

将分区的所有权从一个消费者移到另一个消费者称为重新平衡(rebalance),如何rebalance,就涉及到分区分配策略。

以上,是 Kafka 面试题【Consumer消费Parition的分配策略】的参考答案。

输出,是最好的学习方法

欢迎在评论区留下你的问题、笔记或知识点补充~

—end—

0 条回复 A文章作者 M管理员
    暂无讨论,说说你的看法吧