温馨提示×

ubuntu kafka配置如何启动

小樊
46
2026-08-29 01:26:21
栏目: 智能运维

下面分 本地单节点(开发/测试)常见问题排查 两部分,说明 Ubuntu 上 Kafka 的启动配置方法。假设你已经安装了 Java(Kafka 依赖 Java 8+)。


一、准备环境

1. 安装 Java

sudo apt update
sudo apt install openjdk-17-jdk -y
java -version

二、下载并解压 Kafka(以 3.x 为例)

cd /opt
sudo wget https://downloads.apache.org/kafka/3.6.1/kafka_2.13-3.6.1.tgz
sudo tar -xzf kafka_2.13-3.6.1.tgz
sudo mv kafka_2.13-3.6.1 kafka
cd kafka

三、启动 Zookeeper(Kafka 依赖)

Kafka 3.x 仍默认使用 Zookeeper(KRaft 模式另说)

1. 修改 Zookeeper 配置(可选)

vim config/zookeeper.properties

默认监听:

clientPort=2181

2. 启动 Zookeeper

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

✅ 看到 binding to port 0.0.0.0/0.0.0.0:2181 表示成功


四、启动 Kafka Broker

1. 修改 Kafka 配置

vim config/server.properties

关键配置:

broker.id=0
listeners=PLAINTEXT://localhost:9092
log.dirs=/tmp/kafka-logs
zookeeper.connect=localhost:2181

2. 启动 Kafka

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

✅ 看到 started (kafka.server.KafkaServer) 表示成功


五、验证 Kafka 是否启动成功

1. 创建 Topic

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

2. 查看 Topic

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

3. 发送消息

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

4. 消费消息

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

六、后台运行(推荐)

nohup bin/zookeeper-server-start.sh config/zookeeper.properties > zookeeper.log 2>&1 &
nohup bin/kafka-server-start.sh config/server.properties > kafka.log 2>&1 &

七、常见问题

1. Kafka 启动失败

java.net.UnknownHostException

✅ 解决:

hostname
sudo vim /etc/hosts

添加:

127.0.0.1 your-hostname

2. 端口被占用

sudo netstat -tulnp | grep 9092

3. Ubuntu 22.04 + Kafka 3.x 正常吗?

✅ 完全支持


八、KRaft 模式(无 Zookeeper,可选)

如果你需要 Kafka 3.x 无 Zookeeper 模式,我也可以给你完整配置示例。


如果你愿意,可以告诉我:

  • ✅ Kafka 版本
  • ✅ 是否生产环境
  • ✅ 是否集群

我可以给你 更贴近实际的配置方案

0