当我按键对数据进行分区,然后向 Kafka 中的主题添加新分区时,会发生什么?
现有记录是否会发生变化?未来的数据将如何分区?
当新分区添加到特定主题时,现有数据的分区不会改变。 Kafka 不会尝试重新分发现有记录,此修改只会对新记录产生影响。请注意,默认情况下,Kafka 使用以下方式对数据进行分区hash(key) % noOfPartitions
以确保具有相同键的记录被添加到同一个分区。具有不同键的数据将以循环方式添加到分区中。
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)