kafka如何同步分区的消息数量？

開開新新 发表于: 2020-11-14   最后更新时间: 2020-11-15 03:03:07   1,308 游览 
./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 192.168.10.145:9092 --topic MpMallTest-dev
MpMallTest-dev:0:335
MpMallTest-dev:1:73
MpMallTest-dev:2:35

./kafka-topics.sh --zookeeper localhost:2181 --describe --topic MpMallTest-dev
Topic:MpMallTest-dev    PartitionCount:3    ReplicationFactor:3    Configs:
    Topic: MpMallTest-dev    Partition: 0    Leader: 2    Replicas: 1,2,3    Isr: 2,3,1
    Topic: MpMallTest-dev    Partition: 1    Leader: 3    Replicas: 1,2,3    Isr: 3,2,1
    Topic: MpMallTest-dev    Partition: 2    Leader: 1    Replicas: 1,2,3    Isr: 1,2,3

我们这开发一直都是往0分区写内容，原先ReplicationFactor也是1，我修改了下ReplicationFactor，但是分区数据数量没有因此同步，有什么操作可以修复？ 我使用了./kafka-preferred-replica-election.sh命令没有产生作用

kafka
发表于 2020-11-14
開開新新
添加评论 
./kafka-topics.sh --zookeeper localhost:2181 --describe --topic MpMallTest-dev
Topic:MpMallTest-dev    PartitionCount:3    ReplicationFactor:3    Configs:
    Topic: MpMallTest-dev    Partition: 0    Leader: 1    Replicas: 1,2,3    Isr: 2,3,1
    Topic: MpMallTest-dev    Partition: 1    Leader: 1    Replicas: 1,2,3    Isr: 3,2,1
    Topic: MpMallTest-dev    Partition: 2    Leader: 1    Replicas: 1,2,3    Isr: 1,2,3
./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 192.168.10.145:9092 --topic MpMallTest-dev
MpMallTest-dev:0:335
MpMallTest-dev:1:73
MpMallTest-dev:2:35

另外一个问题，分区1的数据不是最多的，为什么每个分区的Leader都变成broker 1了？

回复
回答于 4年前
開開新新
你的答案

查看kafka相关的其他问题或提一个您自己的问题。
提问

找不到想要的答案？提一个您自己的问题。