首页 文章

Kafka中的PartitionId复制了分区

提问于
浏览
0

我正在实现具有多个分区的单个主题的kafka 生产环境 者 . 我选择消息中的特定值(消息json中的feedName属性值)消息所在的分区 . 我正在为feedName - partitionId映射维护一个SQL表 . 我的问题是,对于领导者和副本,分区ID是否相同?如果不同,如何在所有代理中唯一地识别分区?

2 回答

  • 1

    经纪人的分区ID相同 . 如果没有,会让人感到困惑 .

    分区ID在Zookeeper中维护,所有代理都可以访问Zookeeper . 这就是它的用途 - 因此所有经纪人对主题和分区(以及经纪人)都有相同的观点 .

  • -1

    分区id是不可变的消息序列 . 您可以在Kafka文档中找到相同的内容

    每个分区都是一个有序的,不可变的消息序列,不断附加到提交日志中 .

    在您的用例中,您无需担心id和feedName的映射 .

    希望这可以帮助!

相关问题