温馨提示×

ubuntu kafka配置如何用

小樊
45
2026-09-11 12:20:53
栏目: 智能运维

下面给你一个在 Ubuntu 上配置和使用 Kafka 的简明实战指南,从安装到基本使用,适合新手。


一、环境准备

1. 安装 Java(Kafka 依赖)

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

二、安装 Kafka

方式一:官方二进制包(推荐)

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

三、启动 Kafka(自带 Zookeeper)

1. 启动 Zookeeper

cd /opt/kafka
bin/zookeeper-server-start.sh config/zookeeper.properties

新开一个终端继续操作

2. 启动 Kafka

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

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


四、基础配置说明(重要)

config/server.properties 常见配置

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

如需外网访问:

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

五、Kafka 基本使用

1. 创建 Topic

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

查看 Topic:

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

2. 生产消息(Producer)

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

输入消息后回车发送。


3. 消费消息(Consumer)

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

六、后台运行(推荐)

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

七、常见问题

1. Kafka 启动报错 address already in use

netstat -tunlp | grep 9092

修改 server.properties 端口或杀掉占用进程。

2. 新版本 Kafka(≥3.x)可不用 Zookeeper(KRaft)

如果你用的是 Kafka 3.3+,可以配置 KRaft 模式(更现代)。


八、简单总结

✅ Ubuntu 上 Kafka 使用流程:

  1. 安装 Java
  2. 下载 Kafka
  3. 启动 Zookeeper
  4. 启动 Kafka
  5. 创建 Topic
  6. 生产 / 消费消息

如果你需要:

  • Ubuntu 上 systemd 开机自启
  • Kafka + Python / Java 示例
  • KRaft 模式配置
  • 集群部署

告诉我你的使用场景即可。

0