以下是在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测试消息收发。