在CentOS上设置Kafka,可参考以下步骤:
- 安装Java:Kafka依赖Java环境,使用命令
sudo yum install java-1.8.0-openjdk-devel安装OpenJDK 8,并通过java -version验证安装。 - 下载并解压Kafka:从官网下载Kafka安装包,如
wget https://downloads.apache.org/kafka/3.5.2/kafka_2.12-3.5.2.tgz,然后解压到指定目录,如/usr/local/kafka。 - 配置Kafka:进入
config目录,编辑server.properties文件,设置broker.id、listeners、log.dirs、zookeeper.connect等参数。若需集群部署,还需配置num.partitions、default.replication.factor等参数。 - 配置Zookeeper:若使用Zookeeper,需安装并配置它。下载解压后,编辑
zoo.cfg文件,设置dataDir、clientPort等参数,然后启动Zookeeper服务。 - 启动Kafka:先启动Zookeeper,再启动Kafka服务。可使用命令
bin/kafka-server-start.sh config/server.properties启动Kafka。 - 验证设置:通过创建Topic、发送和接收消息来验证Kafka是否正常工作,如使用
bin/kafka-topics.sh、bin/kafka-console-producer.sh和bin/kafka-console-consumer.sh等命令。 - 设置开机自启动(可选):创建
/etc/systemd/system/kafka.service文件,添加相关内容,然后使用systemctl daemon-reload、systemctl enable kafka和systemctl start kafka命令设置开机自启动。