下面给你一个在 Ubuntu 上配置和使用 Kafka 的简明实战指南,从安装到基本使用,适合新手。
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
cd /opt/kafka
bin/zookeeper-server-start.sh config/zookeeper.properties
新开一个终端继续操作
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
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
bin/kafka-console-producer.sh \
--topic test \
--bootstrap-server localhost:9092
输入消息后回车发送。
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 &
address already in usenetstat -tunlp | grep 9092
修改 server.properties 端口或杀掉占用进程。
如果你用的是 Kafka 3.3+,可以配置 KRaft 模式(更现代)。
✅ Ubuntu 上 Kafka 使用流程:
如果你需要:
告诉我你的使用场景即可。