Apache用于从同一个主题的不同分区中提取消息的算法/策略

Question

我学习阿帕奇卡夫卡已经有一段时间了。

让我们考虑下面的示例。

假设我有一个有3个分区的主题。我只有一个制片人和一个消费者。我在生成消息时没有指定键属性。

所以我知道，在生产者方面，当我发布一条消息时，卡夫卡用来给任何一个分区分配信息的策略都是圆形的-罗宾。

现在，我想知道的是，当我启动一个属于某一消费群体的消费者时，它将使用什么策略从不同的部分(因为有3)提取消息？

它会遵循类似的循环模型吗?在这个模型中，它将向分区1的领导者发送一个获取请求，等待响应，得到响应，返回记录以进行处理。然后，向分区2的领导者发送一个提取请求，等等。

如果它遵循其他策略/算法，我想知道它是什么？

提前谢谢你。

Answer 1

在分区之外没有排序保证，因此在某种程度上，算法对最终用户来说是没有意义的，而且可能会发生变化。

今天，在这种情况下没有什么非常复杂的事情发生。协议向您展示了一个fetch请求包括一个分区，这样您就可以获得每个分区的fetch。这意味着订单取决于消费者。分区不会被饿死，因为对于分配给使用者的所有分区都会发生获取请求。