單機部署

下載二進制包

cd /opt/soft/archive
wget http://archive.apache.org/dist/kafka/3.2.0/kafka_2.12-3.2.0.tgz
tar -zxf kafka_2.12-3.2.0.tgz -C ../
cd ../kafka_2.12-3.2.0

修改配置

vim config/server.propertiesadvertised.listeners=PLAINTEXT://39.105.11.50:9092

啟動

sh bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
sh bin/kafka-server-start.sh  -daemon config/server.properties

集群部署

按照單機部署方式啟動多個Zookeeper與broker節點。
修改config/server.properties配置：

• broker.id 每個節點唯一
• zookeeper.connect： 改成zookeeper節點

查看集群狀態：

bin/kafka-topics.sh --zookeeper <zookeeper_host>:<zookeeper_port> --describe

性能測試

sh bin/kafka-producer-perf-test.sh --help
sh bin/kafka-consumer-perf-test.sh --help