安装Kafka
- 安装Java,因为Kafka运行需要JDK运行环境
sudo yum install java-1.8.0-openjdk-devel.x86_64
如果不知道JDK版本,可以使用下面命令查看可用的JDK版本
sudo yum search openjdk
- 添加EPEL仓库
sudo yum install epel-release
- 下载Kafka
先去查看可以用下载的版本:https://downloads.apache.org/kafka
wget https://downloads.apache.org/kafka/3.7.0/kafka_2.12-3.7.0.tgz
- 解压Kafka
tar -xzf kafka_2.12-3.7.0.tgz
- 移动Kafka文件夹到合适的位置
sudo mv kafka_2.12-2.3.0/* /usr/local/kafka
- 启动Zookeeper服务
nohup /usr/local/kafka/bin/zookeeper-server-start.sh /usr/local/kafka/config/zookeeper.properties &
- 启动Kafka服务
nohup /usr/local/kafka/bin/kafka-server-start.sh /usr/local/kafka/config/server.properties &
修改Kafka配置,使用可以进行远程连接
advertised.listeners=PLAINTEXT://42.194.132.44:9092
注意:这个填写云服务的公网地址
重新Kafka
停止Kafka
sh /usr/local/kafka/bin/kafka-server-stop.sh
启动Kafka
nohup /usr/local/kafka/bin/kafka-server-start.sh /usr/local/kafka/config/server.properties &
防火墙设置
Kafka tool 验证
如图所示Kafka客户端远程连接成功。