1.启动Zookeeper服务

bin/zookeeper-server-start.sh config/zookeeper.properties

2.启动Kafka服务

bin/kafka-server-start.sh config/server.properties

3.创建Topic

bin/kafka-topics.sh --create --topic test --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1

4.发送消息

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

5.接收消息

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

6.创建执行脚本

vi /usr/local/startShell.sh

#!/bin/sh# 进入kafka安装目录
cd /usr/local/kafka_2.12-3.7.0
nohup bin/zookeeper-server-start.sh config/zookeeper.properties > kafka.log 2>&1 &
nohup bin/kafka-server-start.sh config/server.properties > kafka.log 2>&1 &
# 该脚本待优化，不过能用