进入对应安装目录
cd /usr/local/下载对应的安装包
wget https://downloads.apache.org/kafka/3.8.0/kafka_2.13-3.8.0.tgz解压缩
tar zxf kafka_2.13-3.8.0进入安装目录
cd /usr/local/kafka_2.13-3.8.0/修改配置文件
vim ./config/server.properties主要修改以下两行，
其中第一行修改成0.0.0.0主要是让所有机器都可以链接到当前云服务器的kafka，第二行则是填写云服务器外网的ip地址。
listeners=PLAINTEXT://0.0.0.0:9092
advertised.listeners=PLAINTEXT://112.97.63.75:9092然后保存并退出,回到上一页kafka的安装目录
cd /usr/local/kafka_2.13-3.8.0/接着准备后台运行
- 后台运行zookeeper服务
nohup ./bin/zookeeper-server-start.sh ./config/zookeeper.properties > /usr/local/kafka/logs/zookeeper_startup.log 2>&1 &
- 后台运行kafka 服务
nohup ./bin/kafka-server-start.sh ./config/server.properties >/usr/local/kafka/logs/kafka_startup.log 2>&1 &
接着可以创建topic
./bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic hello
启动生产者服务
./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic hello另外启动一个窗口，启动消费者服务
./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092可以通过查看topic 列表来判断kafka服务是否启动成功
./bin/kafka-topics.sh --list --bootstrap-server localhost:9092
如果能看到之前创建的hello topic，类似下图，则证明创建成功
