ubuntu kafka配置怎么连接

下面给你一份在 Ubuntu 上配置并连接 Kafka的简明实战指南，适用于单机（本地）和远程连接两种常见场景。

一、Ubuntu 安装 Kafka（快速版）

1. 安装依赖

sudo apt update
sudo apt install -y default-jdk
java -version

2. 下载 Kafka

wget https://downloads.apache.org/kafka/3.7.0/kafka_2.13-3.7.0.tgz
tar -xzf kafka_2.13-3.7.0.tgz
cd kafka_2.13-3.7.0

二、启动 Kafka（本地连接）

1. 启动 Zookeeper（Kafka 3.0 前需要）

bin/zookeeper-server-start.sh config/zookeeper.properties

2. 启动 Kafka

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

三、关键配置（server.properties）

1. 本地连接（默认即可）

listeners=PLAINTEXT://localhost:9092
advertised.listeners=PLAINTEXT://localhost:9092

2. 远程 / 其他机器连接（重点）

listeners=PLAINTEXT://0.0.0.0:9092
advertised.listeners=PLAINTEXT://你的服务器IP:9092

⚠️ advertised.listeners 必须是客户端能访问到的地址

修改后重启 Kafka：

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

四、测试 Kafka 连接

1. 创建 Topic

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

2. 生产消息

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

3. 消费消息

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

五、用 Java / Python 连接 Kafka

Java（Spring Boot 示例）

spring:
  kafka:
    bootstrap-servers: 192.168.1.100:9092

Python

from kafka import KafkaProducer

producer = KafkaProducer(
    bootstrap_servers='192.168.1.100:9092'
)
producer.send('test', b'hello kafka')

六、常见问题

1. 连接超时

• 防火墙未开放 9092

sudo ufw allow 9092

2. 提示 Connection to node failed

• advertised.listeners 配置错误
• 客户端用了 localhost 但连的是远程服务器

3. Kafka 3.x 可不用 Zookeeper（KRaft）

如果你用的是 Kafka 3.3+，可以不用 Zookeeper，我可以单独给你 KRaft 配置教程。

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

• ✅ 本地还是服务器
• ✅ Kafka 版本
• ✅ 用 Java / Python / Go 还是命令行

我可以给你完全对应的配置示例。