ubuntu kafka配置如何验证

在 Ubuntu 上验证 Kafka 是否配置成功、能否正常工作，可以按下面 由浅入深 的步骤来操作。假设你是通过 官方二进制包 或 Confluent Platform 安装的 Kafka（不是 Docker）。

一、确认 Kafka 相关服务是否启动

1️⃣ 检查 Zookeeper（如果使用）

Kafka 3.x+ 推荐 KRaft，可跳过 Zookeeper

ps aux | grep zookeeper

或查看端口：

netstat -tnlp | grep 2181

2️⃣ 检查 Kafka 进程

ps aux | grep kafka

或检查端口（默认 9092）：

netstat -tnlp | grep 9092

✅ 看到 9092 端口在监听，说明 Kafka 已启动。

二、验证 Kafka 配置文件是否正确

Kafka 配置文件通常位于：

/opt/kafka/config/server.properties

重点检查这几项：

broker.id=0
listeners=PLAINTEXT://localhost:9092
log.dirs=/tmp/kafka-logs
zookeeper.connect=localhost:2181   # KRaft 模式下无此项

✅ 只要 Kafka 能正常启动，配置基本是 OK 的。

三、使用 Kafka 自带脚本进行功能验证（最关键）

1️⃣ 创建 Topic

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

✅ 成功示例：

Created topic test-topic.

2️⃣ 查看 Topic 是否创建成功

bin/kafka-topics.sh \
--list \
--bootstrap-server localhost:9092

或查看详细信息：

bin/kafka-topics.sh \
--describe \
--topic test-topic \
--bootstrap-server localhost:9092

3️⃣ 发送（生产）消息

bin/kafka-console-producer.sh \
--topic test-topic \
--bootstrap-server localhost:9092

输入内容：

hello kafka
ubuntu test

按 Ctrl + C 退出。

4️⃣ 消费消息（验证是否收到）

新开一个终端：

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

✅ 如果看到刚才发送的消息，说明 Kafka 完全配置成功 ✅

四、验证 Kafka 是否可被远程访问（可选）

1️⃣ 修改 server.properties

listeners=PLAINTEXT://0.0.0.0:9092
advertised.listeners=PLAINTEXT://<服务器IP>:9092

2️⃣ 重启 Kafka

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

3️⃣ 从另一台机器测试

bin/kafka-topics.sh \
--bootstrap-server <服务器IP>:9092 \
--list

五、验证 KRaft 模式（Kafka 3.x+）

如果你使用的是 KRaft（无 Zookeeper）：

bin/kafka-metadata-shell.sh \
--snapshot /tmp/kafka-logs/__cluster_metadata-0/00000000000000000000.log

或：

bin/kafka-broker-api-versions.sh --bootstrap-server localhost:9092

六、常见问题排查

❌ Kafka 启动失败

tail -n 100 logs/server.log

❌ Topic 创建失败

java.net.ConnectException

✅ 检查 localhost:9092 是否可达

七、快速验证总结（一句话版）

能创建 Topic + 能生产 + 能消费 = Kafka 配置成功

如果你愿意，可以告诉我：

• Kafka 版本
• 是否使用 KRaft
• 是否本机 or 服务器
• 是否报过具体错误

我可以帮你 精准定位问题 ✅