温馨提示×

ubuntu kafka配置如何验

小樊
36
2026-09-05 16:55:17
栏目: 智能运维

你这个问题里的“验”通常指 验证 Kafka 配置是否生效 / 是否正确。下面按 Ubuntu 环境 给你一套常用、实用的验证方法,从基础到进阶。


一、确认 Kafka 是否启动成功(最基础)

1. 查看进程

ps -ef | grep kafka

应能看到 Kafka 进程。

2. 查看端口

sudo netstat -tunlp | grep 9092
# 或
ss -tunlp | grep 9092

二、验证 server.properties 配置是否生效

1. 常用配置示例(Ubuntu)

broker.id=0
listeners=PLAINTEXT://:9092
advertised.listeners=PLAINTEXT://<你的IP>:9092
log.dirs=/var/lib/kafka/logs
zookeeper.connect=localhost:2181

2. 启动 Kafka

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

三、使用 Kafka 自带命令验证配置

1. 创建 Topic(验证 broker 可用)

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

2. 查看 Topic 列表

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

3. 查看 Topic 详情(验证配置)

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

四、验证生产 / 消费是否正常(核心)

1. 生产者

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

输入:

hello kafka

2. 消费者(新终端)

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

能看到消息即配置正常 ✅


五、验证关键配置项

1. 验证 advertised.listeners

另一台机器执行:

kafka-console-consumer.sh \
  --topic test \
  --bootstrap-server <Ubuntu_IP>:9092

连不上通常是 advertised.listeners 配错。


2. 验证 log.dirs

ls /var/lib/kafka/logs

应有 test-0 目录。


3. 验证 Zookeeper 连接

echo stat | nc localhost 2181

六、查看 Kafka 日志(排错必看)

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

常见错误:

  • Address already in use → 端口冲突
  • Cannot assign requested address → listeners 配置错误
  • Connection refused → broker 未启动

七、快速自检清单 ✅

  • [ ] Kafka 进程存在
  • [ ] 9092 端口监听
  • [ ] Topic 可创建
  • [ ] 生产消费正常
  • [ ] 远程可连接
  • [ ] 日志无报错

如果你愿意,可以:

  • 贴出你的 server.properties
  • 或说明你是 单机 / 集群 / Docker
  • 或具体“验”的是哪一项(监听、远程、性能、权限)

我可以直接帮你逐行检查配置。

0