kafka動態修改 consumer

2021-09-02 00:13:01 字數 891 閱讀 6039

在新版本kafka中,__consumer_offsets這個topic是存放消費者偏移量的,但是該主題預設配置副本數量只有1,容易造成單點故障,我們可以動態修改(無需重啟服務)副本因子,提高kafka的可靠性

1.1動態地增加相關主題的副本數非常的簡單,同樣是使用kafka-reassign-partitions.sh工具來執行,所以我們在操作之前得準備乙個json檔案,裡面詳細地記錄著每個分割槽的副本所在機器等資訊,具體如下:

,,,

,,,,

,,,,

,,,,

,,,,

,,,,

,,,,

,,,,

,,,,

,,,,

,,,,

,,,,

,,

]}

vim replication.json

[root@vm_65_10_centos bin]# ./kafka-reassign-partitions.sh --zookeeper 10.69.65.2:2181 --reassignment-json-file ../explain/replcas.json --execute

[root@vm_65_10_centos bin]# ./kafka-reassign-partitions.sh --zookeeper 10.69.65.2:2181 --reassignment-json-file ../explain/replcas.json --verify

[root@vm_65_10_centos bin]# ./kafka-topics.sh --zookeeper 10.69.65.2:2181 --topic __consumer_offsets --describe

kafka 修改分割槽 kafka分割槽

一 topic下引入partition的作用 topic是邏輯的概念,partition是物理的概念。為了效能考慮,如果topic內的訊息只存於乙個broker,那這個broker會成為瓶頸,無法做到水平擴充套件。kafka通過演算法盡可能的把partition分配到集群的不同伺服器上。partit...

kafka 修改副本數

desc 環境有 6 個 kafka broker,目前是 2副本,考慮將副本數提高到 3 或者 4 新增 kafka 的副本數,提高容災率。該工具可以進行手動分配 partition 到特定的 broker,在特定情況下很有用,比如 某個partition不均衡手動重分 某個broker掛掉了手動...

動態修改布局

在 中設定控制項大小的方法 private button mbtn mbtn button findviewbyid r.id.btn test layoutparams lp lp mbtn.getlayoutparams lp.width 100 lp.height 200 mbtn.setla...