温馨提示×

ubuntu kafka配置如何入门

小樊
45
2026-08-29 02:02:22
栏目: 智能运维

下面给你一个Ubuntu 上手 Kafka 的入门级配置教程,从零开始,适合初学者。你可以按步骤一步一步来。


一、前置条件

1️⃣ 安装 Java(Kafka 依赖)

Kafka 需要 Java 8 或以上版本。

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

验证:

java -version

二、下载并安装 Kafka

1️⃣ 下载 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(单机模式)

Kafka 依赖 Zookeeper(新版本 Kafka 已支持 KRaft,但入门先用 Zookeeper)。

1️⃣ 启动 Zookeeper

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

✅ 看到 binding to port 2181 表示成功


2️⃣ 启动 Kafka

新开一个终端:

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

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


四、创建 Topic(主题)

新开终端:

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

查看 topic:

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

五、测试生产者和消费者

1️⃣ 启动生产者(发送消息)

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

输入内容:

hello kafka

2️⃣ 启动消费者(接收消息)

新终端:

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

✅ 你会看到刚才发送的消息


六、配置文件说明(入门重点)

1️⃣ server.properties(Kafka 核心配置)

位置:

config/server.properties

常用配置:

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

2️⃣ zookeeper.properties

dataDir=/tmp/zookeeper
clientPort=2181

七、常见问题

❓ Kafka 启动失败?

  • 检查 Java 是否安装
  • 端口是否被占用:
netstat -tunlp | grep 9092

❓ 想后台运行?

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

八、下一步学习建议

✅ 学习 Kafka 核心概念

  • Broker
  • Topic
  • Partition
  • Producer / Consumer
  • Consumer Group

✅ 尝试:

  • 多分区 topic
  • 消费者组
  • Python / Java 客户端

如果你愿意,我可以帮你:

  • ✅ 写一个 Python Kafka 入门示例
  • ✅ 配置 Kafka 集群
  • ✅ 用 Docker 安装 Kafka
  • ✅ 解释 Kafka 架构图

你想学哪一部分?

0