ubuntu kafka配置怎样验证

在 Ubuntu 上验证 Kafka 是否配置正确，一般按服务启动 → 基础功能 → 配置参数三个层次来检查。下面给你一套常用、实用的验证方法。

一、确认 Kafka 服务已启动

1. 查看进程

ps -ef | grep kafka

应能看到 kafka.Kafka 相关进程。

2. 查看端口（默认 9092）

netstat -tnlp | grep 9092
# 或
ss -tnlp | grep 9092

3. 查看日志

tail -f /opt/kafka/logs/server.log

（路径按你实际安装位置）

看到类似：

started (kafka.server.KafkaServer)

说明启动成功。

二、使用 Kafka 自带脚本验证（最常用）

1. 创建 Topic

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

2. 查看 Topic 列表

kafka-topics.sh --bootstrap-server localhost:9092 --list

3. 查看 Topic 详情

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

4. 生产消息

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

输入几行内容，回车发送。

5. 消费消息（另开终端）

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

能看到刚才发送的消息，说明 Kafka 配置正常。

三、验证关键配置文件

1. server.properties 重点项

listeners=PLAINTEXT://:9092
advertised.listeners=PLAINTEXT://your-host:9092
zookeeper.connect=localhost:2181
log.dirs=/tmp/kafka-logs

如果远程连接失败，多半是 advertised.listeners 没配好。

2. Zookeeper（老版本 Kafka）

zkServer.sh status

应显示 Mode: standalone 或 leader/follower。

四、远程 / 外部访问验证（可选）

从另一台机器：

kafka-console-consumer.sh \
  --bootstrap-server <ubuntu-ip>:9092 \
  --topic test-topic \
  --from-beginning

如果失败：

• 防火墙：ufw allow 9092
• advertised.listeners 必须是外部可访问 IP

五、常见验证失败原因

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

• Kafka 版本
• 是否用 Docker
• 是本地还是远程访问

我可以直接帮你对照你的配置文件逐步排查。