Kafka重新平衡，以防组中的一个订户被严格分配到特定分区

Question

Kafka重新平衡旨在将主题的所有分区重新分配给订阅组活动成员，以便在任何给定时刻只有一个使用者使用任何主题分区。因此，如果消费者刚刚订阅了一个主题，那么一切都很清楚，但消费者api还提供了一种方法，可以将特定分区分配给消费者：

void分配（集合）

现在假设我们有：

• 一个有5个分区的主题：1,2,3,4,5
• 有3个成员的消费群体：1,2,3
• 成员1和2刚刚订阅了一个主题，成员3已经将分区1分配给自己

那么，在这种情况下，重新平衡将如何工作呢？分区1是否总是分配给成员3（当它还活着的时候），导致其他成员只能从其他分区（2,3,4,5）读取？组协调器是否也可以分配另一个分区给成员3？当成员3关闭后又回来时，分区1会发生什么？

提前谢谢




Answer 1

在Kafka文档中找到：

<代码>公共空分配（集合

通过此方法进行的手动主题分配不使用使用者的组管理功能。因此，当组成员资格或群集和主题元数据更改时，不会触发重新平衡操作。请注意，不可能同时使用带分配（集合）的手动分区分配和带订阅（集合，消费者重新平衡监听器）的组分配。

因此，组中的所有使用者都应该使用手动分区分配或仅使用订阅（获取分区的动态分配）。