工具類--字符集工具類
----------------Kafka叢集部署---------------
環境準備：虛擬機器三臺（可以聯網）
步驟一：_________________________
關閉防火牆 和 selinux
systemctl stop firewalld
setenforce 0
步驟二：_________________________
下載kafka包並解壓
yum install -y java-1.8.0-openjdk java-1.8.0-openjdk-devel
yum install -y wget
下載 ： wget https://dlcdn.apache.org/kafka/3.0.0/kafka_2.12-3.0.0.tgz --no-check-certificate
解壓 ：tar xvf kafka_2.12-3.0.0.tgz -C /root/
步驟三：_________________________
編輯檔案內容
vi /root/kafka_2.12-3.0.0/config/server.properties
在檔案末尾新增下面的內容( broker.id=一節點是1，二節點是2.。。。。。IP1,2,3為三臺節點IP,listeners中輸入當前節點IP地址)
broker.id=1
zookeeper.connect=IP1:2181,IP2:2181,IP3:2181
listeners = PLAINTEXT://當前節點IP:9092
步驟三：_________________________
啟動服務：
/root/kafka_2.12-3.0.0/bin/kafka-server-start.sh -daemon /root/kafka_2.12-3.0.0/config/server.properties
檢視服務是否啟動
jps << 命令
測試：
（在第一節點執行）： /root/kafka_2.12-3.0.0/bin/kafka-topics.sh --create --zookeeper 172.16.51.23:2181 --replication-factor 1 --partitions 1 --topic test
（在第二節點執行）： /root/kafka_2.12-3.0.0/bin/kafka-topics.sh--list --zookeeper 二節點IP:2181
（在第三節點執行）： /root/kafka_2.12-3.0.0/bin/kafka-topics.sh--list --zookeeper 三節點IP:2181