在Debian上部署Kafka集群涉及多個步驟,包括安裝和配置Zookeeper、Kafka Broker集群、創建主題以及監控和管理集群狀態。以下是一個詳細的步驟指南:
下載并解壓Zookeeper:
wget https://downloads.apache.org/zookeeper/stable/apache-zookeeper-3.7.0-bin.tar.gz
tar -xvzf apache-zookeeper-3.7.0-bin.tar.gz
cd apache-zookeeper-3.7.0-bin
配置Zookeeper:編輯conf/zoo.cfg
文件,設置集群節點和數據目錄等參數:
tickTime=2000
initLimit=5
syncLimit=2
dataDir=/var/lib/zookeeper
clientPort=2181
server.1=zk-node1:2888:3888
server.2=zk-node2:2888:3888
server.3=zk-node3:2888:3888
啟動Zookeeper集群:
bin/zkServer.sh start
bin/zkServer.sh status
下載并解壓Kafka:
wget https://downloads.apache.org/kafka/2.8.0/kafka_2.13-2.8.0.tgz
tar -xvzf kafka_2.13-2.8.0.tgz
cd kafka_2.13-2.8.0
配置Kafka:編輯config/server.properties
文件,設置必要的參數,如broker.id
、listeners
、log.dirs
等:
broker.id=1
listeners=PLAINTEXT://kafka-node1:9092
log.dirs=/var/lib/kafka/logs
zookeeper.connect=zk-node1:2181,zk-node2:2181,zk-node3:2181
啟動Kafka Broker:
bin/kafka-server-start.sh config/server.properties
bin/kafka-topics.sh --create --topic my-topic --bootstrap-server localhost:9092 --replication-factor 3 --partitions 3
bin/kafka-topics.sh --list --zookeeper localhost:2181
kafka-topics.sh
、kafka-consumer-groups.sh
等來監控和管理集群狀態。