下面给你一个Ubuntu 上手 Kafka 的入门级配置教程,从零开始,适合初学者。你可以按步骤一步一步来。
Kafka 需要 Java 8 或以上版本。
sudo apt update
sudo apt install openjdk-11-jdk -y
验证:
java -version
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(新版本 Kafka 已支持 KRaft,但入门先用 Zookeeper)。
cd /opt/kafka
bin/zookeeper-server-start.sh config/zookeeper.properties
✅ 看到 binding to port 2181 表示成功
新开一个终端:
cd /opt/kafka
bin/kafka-server-start.sh config/server.properties
✅ 看到 started (kafka.server.KafkaServer) 表示成功
新开终端:
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
bin/kafka-console-producer.sh \
--topic test-topic \
--bootstrap-server localhost:9092
输入内容:
hello kafka
新终端:
bin/kafka-console-consumer.sh \
--topic test-topic \
--from-beginning \
--bootstrap-server localhost:9092
✅ 你会看到刚才发送的消息
server.properties(Kafka 核心配置)位置:
config/server.properties
常用配置:
broker.id=0
log.dirs=/tmp/kafka-logs
listeners=PLAINTEXT://localhost:9092
zookeeper.connect=localhost:2181
zookeeper.propertiesdataDir=/tmp/zookeeper
clientPort=2181
netstat -tunlp | grep 9092
nohup bin/kafka-server-start.sh config/server.properties > kafka.log 2>&1 &
✅ 学习 Kafka 核心概念
✅ 尝试:
如果你愿意,我可以帮你:
你想学哪一部分?