当我们在运行时增加分区时，Kafka如何保证消息顺序？

如何解决当我们在运行时增加分区时，Kafka如何保证消息顺序？

我是kafka的新手，当我阅读Kafka文档时，我意识到带有相同密钥的消息将被映射到同一分区以保证顺序。这完全有道理。但是，我想知道是否在运行时增加了主题分区的数量，具有相同键的新消息是否会像以前一样被散列到相同的分区（旧的）？

如果是这样，如果所有消息都提供了密钥怎么办，那么它们都不会被映射到新分区？这对我来说没有意义。

如果不是，那么Kafka如何保证按顺序发送具有相同密钥的邮件的顺序？

解决方法

我想知道是否在运行时增加了主题分区的数量，是否将具有相同密钥的新消息像以前一样哈希到相同的分区（旧分区）上？

否，新消息将根据新的分区数进行分区。旧邮件不会重新分区。

如果不是，那么Kafka如何保证按顺序发送具有相同密钥的邮件的顺序？

更改分区数时无法保证。当在运行时增加（或减少）分区数量时，顺序可能会改变，甚至会更好。

因此，如果您依赖于数据的顺序，则不建议更改已经包含数据的主题的分区。你能做的就是

• 在使生产者向其发送数据之前，将现有数据复制到具有新分区数量的新主题中。
• 在生产者中应用自定义分区程序，该程序将基于密钥的消息发送到固定分区，并且只有“新密钥”发送到新分区。