Kafka中的消息怎样分配给差异的消耗者？

各人好，我是锋哥。本日禀享关于【Kafka中的消息怎样分配给差异的消耗者？】口试题。渴望对各人有资助；

Kafka中的消息怎样分配给差异的消耗者？

在 Kafka 中，消息是通过 主题（Topic） 举行构造的，而消耗者则通过 消耗者组（Consumer Group） 来消耗这些消息。Kafka 中的消息怎样分配给差异的消耗者，紧张由以下几个关键概念决定：
1. 主题和分区（Partition）

Kafka 中的每个主题可以包罗多个 分区（Partition）。每个分区是一个独立的消息队列，它可以或许存储消息并按序次消耗。一个主题的多个分区允许 Kafka 扩展吞吐量，而且可以均衡负载。
2. 消耗者组（Consumer Group）

Kafka 中的消耗者被构造到一个或多个 消耗者组 中。每个消耗者组有一个独立的消耗进度（offset），而且每个消耗者组中的消耗者在消耗消息时，确保每条消息只能被组内的一个消耗者消耗。
3. 消耗者与分区的关系

在 Kafka 中，消息的分配规则依照以下原则：

• 每个消耗者组中的消耗者会只管匀称地分配到各个 分区 上。每个消耗者组中的消耗者可以消耗多个分区，但每个分区 只能被一个消耗者组中的一个消耗者消耗。
  
• 如果消耗者数目少于分区数目，某些消耗者将会消耗多个分区。
  
• 如果消耗者数目大于分区数目，某些消耗者将会处于空闲状态，无法分配到分区。
  

4. 分配计谋

Kafka 利用两种紧张的分配计谋来决定怎样将分区分配给消耗者：

• Range（范围分配）：将分区按范围分配给消耗者。比方，消耗者1消耗分区0和1，消耗者2消耗分区2和3，依此类推。
  
• Round-robin（轮询分配）：将分区以轮询的方式分配给消耗者。比方，如果有 4 个分区和 2 个消耗者，消耗者1消耗分区0和2，消耗者2消耗分区1和3。
  

分配计谋可以在启动消耗者时举行设置。
5. 消耗者的负载均衡

Kafka 会动态调解消耗者的分配情况，以应对消耗者的参加或脱离。比方，如果一个消耗者参加消耗者组，Kafka 会重新均衡分区的分配，确保每个消耗者可以或许均衡地处置处罚消息。
6. 消耗进度（Offset）

每个消耗者（大概消耗者组）会记录自己消耗的消息位置，即 offset。在 Kafka 中，offset 是一个分区内消息的唯一标识。消耗者会不停提交自己的 offset，以便在重新启动或发生故障时，可以从前次消耗的地方继承。
总结：

Kafka 中的消息分配是通过 消耗者组 和 分区 的关系来举行的。每个消耗者组中的消耗者会根据分区的数目和分配计谋来消耗消息，并确保每个分区中的消息被唯一的消耗者消耗。分配计谋包罗范围分配（Range）和轮询分配（Round-robin），Kafka 会根据消耗者组内消耗者的数目动态调解分配。