参考官方文档，一步步执行 https://kafka.apache.org/documentation/#quickstart
（1）下载最新版Kafka
代码语言：javascript复制[root@node1 app]# tar -zxvf kafka_2.13-2.8.0.tgz
[root@node1 app]# mv kafka_2.13-2.8.0 kafka-2.8.0
[root@node1 app]# cd kafka-2.8.0/（2）启动Kafka环境 先启动内置的Zookeeper
代码语言：javascript复制[root@node1 kafka-2.8.0]# bin/zookeeper-server-start.sh config/zookeeper.properties再打开一个终端创建，启动Kafka环境
代码语言：javascript复制[root@node1 ~]# cd /app/kafka
kafka_2.13-2.8.0.tgz kafka-2.8.0/
[root@node1 ~]# cd /app/kafka-2.8.0/
[root@node1 kafka-2.8.0]# bin/kafka-server-start.sh config/server.properties（3）创建一个topic 重新打开一个终端窗口
代码语言：javascript复制[root@node1 kafka-2.8.0]# bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092
Created topic quickstart-events.
[root@node1 kafka-2.8.0]# bin/kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092
Topic: quickstart-events TopicId: E3JG3XNrTpapreJwaD4UdQ PartitionCount: 1 ReplicationFactor: 1 Configs: segment.bytes=1073741824
Topic: quickstart-events Partition: 0 Leader: 0 Replicas: 0 Isr: 0
[root@node1 kafka-2.8.0]# （4）启动生产者发送消息
代码语言：javascript复制[root@node1 kafka-2.8.0]# bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092
>hi
>hello
>（5）启动消费者消费消息
代码语言：javascript复制连接成功
Last login: Sat Sep 4 10:44:11 2021 from 192.168.9.1
[root@node1 ~]# cd /app/kafka-2.8.0/
[root@node1 kafka-2.8.0]# bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092
hi
hello
（6）测试完成，清理环境 通过CTRL C键即可停止环境，请注意先后顺序。
- 停止生产者和消费者
- 停止Kafka broker
- 停止Zookeeper
最后再删除数据目录
代码语言：javascript复制[root@node1 kafka-2.8.0]# rm -rf /tmp/kafka-logs /tmp/zookeeper
