通過命令查看結果如下

我的broker節點只有3個，但是這個副本數設置成了4。

因此判斷是副本數設置的問題。多多了的1,2,3什麽的都不存在的。

通過以下腳本修改副本數即可。

cat > increase-replication-factor.json <<EOF
{"version":1, "partitions":[
{"topic":"topic.toTiDB.shebox.dau","partition":0,"replicas":[65,66]},
{"topic":"topic.toTiDB.shebox.dau","partition":1,"replicas":[67,65]},
{"topic":"topic.toTiDB.shebox.dau","partition":2,"replicas":[66,67]}]
}
EOF

./kafka-reassign-partitions.sh --zookeeper localhost:2181 --reassignment-json-file /tmp/increase-replication-factor.json --execute
 

kafka分區停留在UnderReplicated狀態