下面分 本地单节点(开发/测试) 和 常见问题排查 两部分,说明 Ubuntu 上 Kafka 的启动配置方法。假设你已经安装了 Java(Kafka 依赖 Java 8+)。
sudo apt update
sudo apt install openjdk-17-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 kafka
Kafka 3.x 仍默认使用 Zookeeper(KRaft 模式另说)
vim config/zookeeper.properties
默认监听:
clientPort=2181
bin/zookeeper-server-start.sh config/zookeeper.properties
✅ 看到 binding to port 0.0.0.0/0.0.0.0:2181 表示成功
vim config/server.properties
关键配置:
broker.id=0
listeners=PLAINTEXT://localhost:9092
log.dirs=/tmp/kafka-logs
zookeeper.connect=localhost:2181
bin/kafka-server-start.sh config/server.properties
✅ 看到 started (kafka.server.KafkaServer) 表示成功
bin/kafka-topics.sh \
--bootstrap-server localhost:9092 \
--create \
--topic test-topic \
--partitions 1 \
--replication-factor 1
bin/kafka-topics.sh --bootstrap-server localhost:9092 --list
bin/kafka-console-producer.sh \
--bootstrap-server localhost:9092 \
--topic test-topic
bin/kafka-console-consumer.sh \
--bootstrap-server localhost:9092 \
--topic test-topic \
--from-beginning
nohup bin/zookeeper-server-start.sh config/zookeeper.properties > zookeeper.log 2>&1 &
nohup bin/kafka-server-start.sh config/server.properties > kafka.log 2>&1 &
java.net.UnknownHostException
✅ 解决:
hostname
sudo vim /etc/hosts
添加:
127.0.0.1 your-hostname
sudo netstat -tulnp | grep 9092
✅ 完全支持
如果你需要 Kafka 3.x 无 Zookeeper 模式,我也可以给你完整配置示例。
如果你愿意,可以告诉我:
我可以给你 更贴近实际的配置方案。