kafka 修改副本數

desc: 環境有 6 個 kafka broker，目前是 2副本，考慮將副本數提高到 3 或者 4 ，新增 kafka 的副本數，提高容災率。

該工具可以進行手動分配 partition 到特定的 broker，在特定情況下很有用，比如：某個partition不均衡手動重分、某個broker掛掉了手動增加replica冗餘。

# foo topic 的 partition 0 原本 leader 44，replica 為44、45 isr 為 44、45；此時45broker宕機，為了防止44也宕機然後造成整個kafka不可用，可以通過如下方式增加46作為replica

$ ./bin/kafka-reassign-partitions.sh --zookeepeer data01.sa:
2181
--reassignment-json-file partitions-to-move.json --execute
$ cat partitions-to-move.json],
"version":1
}

kafka修改分割槽和副本數

檢視現在副本分配情況 bin kafka topics.sh zookeeper 127.0.0.1 2181 describe topic test1 topic test1 partitioncount 3 replicationfactor 2 configs topic test1 part...

設定上傳副本數

1.在src main resources資料夾下建立 hdfs site.xml 檔案 1 23 45 6dfs.replication78 1910 2.檔案上傳 1 檔案上傳 2 test 3public void testcopyfromlocalfeil throws ioexceptio...

kafka 副本機制

kafka通過副本機制保證資料的可靠性 一.副本機制的概念如下 1.乙個partition有多個副本replication,一般是3個或5個 2.每個副本位於不通的broker 3.每個副本集合裡有乙個leader副本,其餘的為follower副本,只有leader副本才接受讀寫請求,followe...