下面以 Debian 系(Debian / Ubuntu) 为例,说明 Kafka 安装后的基本配置流程。假设你已经装好了 Java 和 Kafka(通过官方二进制包,不推荐 apt 直接装旧版本)。
sudo apt update
sudo apt install openjdk-17-jdk -y
java -version
cd /opt
sudo wget https://downloads.apache.org/kafka/3.7.0/kafka_2.13-3.7.0.tgz
sudo tar -xzf kafka_2.13-3.7.0.tgz
sudo mv kafka_2.13-3.7.0 kafka
/opt/kafka/config/
├── server.properties # Kafka 主配置
├── zookeeper.properties # Zookeeper 配置(Kafka 3.0+ 可选)
server.propertiessudo nano /opt/kafka/config/server.properties
最小可用配置:
broker.id=0
listeners=PLAINTEXT://:9092
advertised.listeners=PLAINTEXT://<你的IP或域名>:9092
log.dirs=/tmp/kafka-logs
num.partitions=1
offsets.topic.replication.factor=1
⚠️ 如果是云服务器,
advertised.listeners必须配置成外部可访问地址
sudo nano /opt/kafka/config/zookeeper.properties
dataDir=/tmp/zookeeper
clientPort=2181
# 启动 Zookeeper
/opt/kafka/bin/zookeeper-server-start.sh -daemon /opt/kafka/config/zookeeper.properties
# 启动 Kafka
/opt/kafka/bin/kafka-server-start.sh -daemon /opt/kafka/config/server.properties
# 生成集群 ID
KAFKA_CLUSTER_ID=$(/opt/kafka/bin/kafka-storage.sh random-uuid)
# 格式化
/opt/kafka/bin/kafka-storage.sh format -t $KAFKA_CLUSTER_ID -c /opt/kafka/config/kraft/server.properties
# 启动
/opt/kafka/bin/kafka-server-start.sh -daemon /opt/kafka/config/kraft/server.properties
# 创建 topic
/opt/kafka/bin/kafka-topics.sh --create \
--topic test \
--bootstrap-server localhost:9092 \
--partitions 1 --replication-factor 1
# 查看 topic
/opt/kafka/bin/kafka-topics.sh --list --bootstrap-server localhost:9092
num.network.threads=3
num.io.threads=8
socket.send.buffer.bytes=102400
socket.receive.buffer.bytes=102400
log.retention.hours=168
default.replication.factor=3
min.insync.replicas=2
如需要,我可以给你 完整 systemd 服务文件(Kafka / Zookeeper / KRaft)。
sudo ufw allow 9092
advertised.listeners 配错如果你愿意,可以告诉我:
我可以直接给你 可用的完整配置文件 + systemd 脚本。