当我按密钥对数据进行分区,然后在Kafka中添加新的分区时会发生什么



当我按密钥分区数据,然后在kafka中添加新的分区时会发生什么?

现有记录会有任何更改吗?以及将来的数据将如何分区?

当新分区添加到特定主题中时,现有数据的分区不会更改。Kafka不会尝试重新分发现有记录,此修改只会对新记录产生影响。请注意,默认情况下,Kafka使用hash(key) % noOfPartitions分区数据,以确保将具有相同键的记录添加到同一分区中。带有不同键的数据将以圆形旋转方式添加到分区中。

最新更新