在Linux上對Kafka進行擴容通常涉及以下幾個步驟:
server.properties
)。kafka-reassign-partitions.sh
腳本重新分配現有的分區副本到新的Broker上。./bin/kafka-reassign-partitions.sh --zookeeper zkhost:port \
--topics-to-move-json-file kafka/config/topic.json \
--broker-list "broker1:9092,broker2:9092,..." \
--generate
其中broker1:9092,broker2:9092,...
是新的Broker列表。./bin/kafka-reassign-partitions.sh --zookeeper zkhost:port \
--reassignment-json-file config/reassignment.json \
--execute
執行后再通過以下命令驗證:
./bin/kafka-reassign-partitions.sh --zookeeper zkhost:port \
--reassignment-json-file config/reassignment.json \
--verify
df -h
fdisk
或parted
等工具對磁盤進行分區,創建新的物理卷并添加到現有的卷組(VG)中。fdisk /dev/vdc
# 按照提示操作,刪除舊分區并創建新分區
lvextend
命令擴展邏輯卷的大小。lvextend -L +20G /dev/mapper/rhel-root
xfs_growfs /dev/mapper/rhel-root
acks
設置為-1
,min.insync.replicas
設置為1
,以保證數據的一致性和可用性。在進行任何操作之前,請確保備份所有重要數據,并在非生產環境中充分測試。