安装

官方文档：https://kafka.apache.org/quickstart

第一步：下载

地址：https://www.apache.org/dyn/closer.cgi?path=/kafka/3.2.0/kafka_2.13-3.2.0.tgz。

kafka_2.13-3.2.0.tgz 其中 2.13 是 scala 的版本，3.2.0 是 kafka版本。（kafka是用scala写的，所所以安装 scala 前本地先装scala）。

tar -xzf kafka_2.13-3.2.0.tgz
cd kafka_2.13-3.2.0

第二步：启动kafka环境

要求本地的本地必须安装 jdk8或者以上版本，因为scala运行在jvm上。启动 zookeeper：

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

重新打开终端执行命令，启动 Kafka broker service。

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

第三步：创建 topic

bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092

查看 topic 的描述

bin/kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092

第四步：写数据到 topic

bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092
This is my first event
This is my second event

按 ctrl+c 结束写数据

第五步：读数据

bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092
This is my first event
This is my second event

按 ctrl+c 结束读数据