在CentOS上配置Kafka集群一般有以下步骤:
sudo yum install java-1.8.0-openjdk-devel
命令安装OpenJDK 8。wget https://downloads.apache.org/kafka/3.6.1/kafka_2.13-3.6.1.tgz
,然后解压。config/zookeeper.properties
,设置dataDir
、clientPort
和server.x
等参数;若单独部署,需在Zookeeper服务器上创建数据目录和myid
文件。config/server.properties
,为每个节点设置唯一的broker.id
,配置监听地址listeners
、日志路径log.dirs
和Zookeeper连接地址zookeeper.connect
。bin/kafka-server-start.sh -daemon config/server.properties
启动Kafka服务。kafka-topics.sh
创建主题,查看主题列表,启动生产者和消费者测试消息的生产和消费。