以下是在Linux上搭建Kafka集群的步驟解析:
JAVA_HOME
。/usr/local/zookeeper
。zoo.cfg
,設置dataDir
、clientPort
,添加集群節點信息server.X
。dataDir
下創建myid
,內容為節點編號。bin/zkServer.sh start
。/usr/local/kafka
。server.properties
,設置broker.id
(唯一)、listeners
、log.dirs
,若用Zookeeper還需設置zookeeper.connect
;若用KRaft模式(Kafka 4.0+),配置controller.quorum.voters
等。bin/kafka-server-start.sh config/server.properties
。kafka-topics.sh
創建測試主題,指定副本數和分區數。kafka-console-producer.sh
和kafka-console-consumer.sh
測試消息收發。