本次操作会以 Linux 作为依据前置条件首先我们需要安装JDK# 更新源 sudo apt update # 安装JDK11 sudo apt install openjdk-11-jdk -y # 验证java java -version下载Kafka# 下载3.7.1稳定版可替换最新版本 wget https://archive.apache.org/dist/kafka/3.7.1/kafka_2.13-3.7.1.tgz # 解压 tar -zxvf kafka_2.13-3.7.1.tgz # 移动到/usr/local统一目录 sudo mv kafka_2.13-3.7.1 ~/kafka # 进入目录 cd /usr/local/kafka配置环境变量# 编辑环境变量 sudo vim /etc/profile# 末尾添加 export KAFKA_HOME/usr/local/kafka export PATH$PATH:$KAFKA_HOME/bin# 生效配置 source /etc/profile单机版本验证后台启动Zookeeper# 方式1后台运行 nohup bin/zookeeper-server-start.sh config/zookeeper.properties zk.log 21 # 查看日志验证启动 tail -f zk.log后台启动 Kafka 服务nohup bin/kafka-server-start.sh config/server.properties kafka.log 21 # 查看kafka日志 tail -f kafka.log测试命令# 创建 topic bin/kafka-topics.sh --create --topic test_topic --bootstrap-server localhost:9092 --partitions 1 --replication-factor 1 # 查看 topic 列表 bin/kafka-topics.sh --list --bootstrap-server localhost:9092 # 生产者发送消息 bin/kafka-console-producer.sh --topic test_topic --bootstrap-server localhost:9092 # 消费者消费消息 bin/kafka-console-consumer.sh --topic test_topic --from-beginning --bootstrap-server localhost:9092 # 删除测试主题 bin/kafka-topics.sh --delete --topic test_topic --bootstrap-server localhost:9092停止服务# 关闭kafka bin/kafka-server-stop.sh # 关闭zookeeper bin/zookeeper-server-stop.sh