Kafka 完整一键部署+测试总结（路径：/root/kafka）

我把安装 → 排错修复 → 创建主题 → 收发消息全流程整理成可直接复制执行的完整版，所有主题统一为 log，路径统一为 /root/kafka，包含创建失败时的重置重启方案。

一、前置准备（下载+解压）

# 进入根目录
cd /root

# 下载 Kafka（2.13-3.6.1 稳定版）
wget https://archive.apache.org/dist/kafka/3.6.1/kafka_2.13-3.6.1.tgz

# 解压并重命名为 kafka
tar -zxvf kafka_2.13-3.6.1.tgz
mv kafka_2.13-3.6.1 kafka

# 进入 bin 目录
cd /root/kafka/bin

二、标准启动流程（先ZK，后Kafka）

# 1. 启动 Zookeeper（Kafka 必须依赖）
./zookeeper-server-start.sh -daemon ../config/zookeeper.properties
sleep 8

# 2. 启动 Kafka
./kafka-server-start.sh -daemon ../config/server.properties
sleep 15

三、创建失败？一键重置（清除配置+重启）

如果出现 连接失败/创建topic失败，执行这段彻底重置：

cd /root/kafka/bin

# 停止服务
./kafka-server-stop.sh
./zookeeper-server-stop.sh
sleep 5

# 删除 Kafka 数据目录（重置配置）
rm -rf /tmp/kafka-logs /tmp/zookeeper
sleep 3

# 重新启动
./zookeeper-server-start.sh -daemon ../config/zookeeper.properties
sleep 8
./kafka-server-start.sh -daemon ../config/server.properties
sleep 15

四、创建主题（统一名称：log）

cd /root/kafka/bin
./kafka-topics.sh --create \
  --bootstrap-server localhost:9092 \
  --topic log \
  --partitions 1 \
  --replication-factor 1

五、测试：发送消息 + 接收消息

1. 启动生产者（发消息）

cd /root/kafka/bin
./kafka-console-producer.sh --bootstrap-server localhost:9092 --topic log

输入内容按回车即可发送，例如：

test log 1
test log 2

2. 新开终端，启动消费者（收消息）

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

✅ 能看到发送的所有消息 = Kafka 完全正常

六、常用辅助命令

# 查看主题列表
./kafka-topics.sh --list --bootstrap-server localhost:9092

# 查看 log 主题详情
./kafka-topics.sh --describe --bootstrap-server localhost:9092 --topic log

# 停止 Kafka + ZK
./kafka-server-stop.sh
./zookeeper-server-stop.sh

完整流程总结

1. 安装：wget 下载 → 解压到 /root/kafka
2. 启动：先 Zookeeper，后 Kafka
3. 失败修复：停止服务 → 删除数据目录 → 重启
4. 创建主题：统一主题名 log
5. 功能测试：生产者发消息 + 消费者收消息
6. 路径统一：所有操作均在 /root/kafka 下完成