要系统学习 Ubuntu 下 Kafka 的配置与使用,可以按下面这条主线来,从环境准备 → 安装 → 核心配置 → 实践 → 排错,循序渐进。
虽然可以直接上手,但建议你至少了解:
Linux 基础
Java 基础概念
消息队列基本概念
sudo apt update
sudo apt install openjdk-17-jdk -y
java -version
Kafka 3.x 推荐 Java 11 或 17
wget https://downloads.apache.org/kafka/3.6.1/kafka_2.13-3.6.1.tgz
tar -xzf kafka_2.13-3.6.1.tgz
cd kafka_2.13-3.6.1
bin/zookeeper-server-start.sh config/zookeeper.properties
bin/kafka-server-start.sh config/server.properties
路径:
config/server.properties
broker.id=0
listeners=PLAINTEXT://localhost:9092
log.dirs=/tmp/kafka-logs
num.partitions=1
offsets.topic.replication.factor=1
✅ 建议理解:
dataDir=/tmp/zookeeper
clientPort=2181
✅ 理解 Zookeeper 作用:
config/producer.properties
config/consumer.properties
常用:
bootstrap.servers=localhost:9092
bin/kafka-topics.sh --create \
--topic test-topic \
--bootstrap-server localhost:9092 \
--partitions 3 \
--replication-factor 1
bin/kafka-topics.sh --list --bootstrap-server localhost:9092
bin/kafka-console-producer.sh \
--topic test-topic \
--bootstrap-server localhost:9092
bin/kafka-console-consumer.sh \
--topic test-topic \
--from-beginning \
--bootstrap-server localhost:9092
示例:
[Unit]
Description=Kafka Broker
[Service]
ExecStart=/opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/server.properties
Restart=always
[Install]
WantedBy=multi-user.target
sudo ufw allow 9092
检查:
listeners=PLAINTEXT://0.0.0.0:9092
advertised.listeners=PLAINTEXT://你的IP:9092
df -h
du -sh /tmp/kafka-logs
✅ 入门
✅ 进阶 2. 《Kafka 权威指南》 3. Confluent 官方博客
✅ 实战
你可以直接告诉我你的目标,例如:
我可以按你的目标给你 定制学习路线 + 实战示例。