阅读量:4
以下是在CentOS上安装Kafka的步骤(以单机为例):
-
安装Java(Kafka依赖Java)
sudo yum install java-1.8.0-openjdk-devel -y java -version # 验证安装 -
下载Kafka
从官网下载对应版本(如3.6.2),使用wget命令:wget https://downloads.apache.org/kafka/3.6.2/kafka_2.13-3.6.2.tgz -
解压并配置环境变量
tar -xzf kafka_2.13-3.6.2.tgz -C /opt mv kafka_2.13-3.6.2 kafka # 可选:重命名 echo 'export KAFKA_HOME=/opt/kafka' >> /etc/profile echo 'export PATH=$PATH:$KAFKA_HOME/bin' >> /etc/profile source /etc/profile -
配置Kafka
编辑config/server.properties:- 设置
broker.id(单机可设为0) - 配置监听地址
listeners=PLAINTEXT://your_server_ip:9092 - 配置日志路径
log.dirs=/opt/kafka/logs - 配置Zookeeper连接
zookeeper.connect=localhost:2181
- 设置
-
启动Zookeeper(Kafka依赖)
cd /opt/kafka bin/zookeeper-server-start.sh config/zookeeper.properties & -
启动Kafka
bin/kafka-server-start.sh config/server.properties & -
验证安装
- 创建Topic:
bin/kafka-topics.sh --create --topic test --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 - 查看Topic列表:
bin/kafka-topics.sh --list --bootstrap-server localhost:9092 - 生产/消费消息(可选):
# 生产者 bin/kafka-console-producer.sh --topic test --bootstrap-server localhost:9092 # 消费者 bin/kafka-console-consumer.sh --topic test --from-beginning --bootstrap-server localhost:9092
- 创建Topic:
可选步骤:
- 配置开机自启动(需创建systemd服务文件)。
- 关闭防火墙或放通9092端口(生产环境需操作)。
参考来源:
以上就是关于“kafka在centos上的安装步骤是什么”的相关介绍,筋斗云是国内较早的云主机应用的服务商,拥有10余年行业经验,提供丰富的云服务器、租用服务器等相关产品服务。云服务器资源弹性伸缩,主机vCPU、内存性能强悍、超高I/O速度、故障秒级恢复;电子化备案,提交快速,专业团队7×24小时服务支持!
简单好用、高性价比云服务器租用链接:https://www.jindouyun.cn/product/cvm