下面是在 Debian 系统上安装 Apache Kafka 的完整步骤示例(以 Kafka 3.x + Java 17 为例,适用于 Debian 11/12)。
sudo apt update
sudo apt upgrade -y
Kafka 3.x 建议使用 Java 17 或 Java 11。
sudo apt install openjdk-17-jdk -y
验证:
java -version
cd /opt
前往官网获取最新版本地址:
https://kafka.apache.org/downloads
示例(以 3.7.0 为例):
wget https://downloads.apache.org/kafka/3.7.0/kafka_2.13-3.7.0.tgz
tar -xzf kafka_2.13-3.7.0.tgz
mv kafka_2.13-3.7.0 kafka
Kafka 新版本已逐步移除 Zookeeper,但当前仍可用。
cd /opt/kafka
bin/zookeeper-server-start.sh config/zookeeper.properties
可加
&后台运行,或另开终端
bin/kafka-server-start.sh config/server.properties
bin/kafka-topics.sh \
--create \
--topic test-topic \
--bootstrap-server localhost:9092 \
--partitions 1 \
--replication-factor 1
bin/kafka-topics.sh --list --bootstrap-server localhost:9092
bin/kafka-console-producer.sh \
--topic test-topic \
--bootstrap-server localhost:9092
输入内容后按 Ctrl+C 退出。
bin/kafka-console-consumer.sh \
--topic test-topic \
--from-beginning \
--bootstrap-server localhost:9092
sudo nano /etc/systemd/system/zookeeper.service
内容:
[Unit]
Description=Zookeeper Service
After=network.target
[Service]
Type=simple
ExecStart=/opt/kafka/bin/zookeeper-server-start.sh /opt/kafka/config/zookeeper.properties
ExecStop=/opt/kafka/bin/zookeeper-server-stop.sh
Restart=on-failure
[Install]
WantedBy=multi-user.target
sudo nano /etc/systemd/system/kafka.service
内容:
[Unit]
Description=Apache Kafka
After=zookeeper.service
[Service]
Type=simple
ExecStart=/opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/server.properties
ExecStop=/opt/kafka/bin/kafka-server-stop.sh
Restart=on-failure
[Install]
WantedBy=multi-user.target
sudo systemctl daemon-reload
sudo systemctl start zookeeper
sudo systemctl start kafka
设置开机自启:
sudo systemctl enable zookeeper
sudo systemctl enable kafka
检查:
java -version
netstat -tulnp | grep 9092
sudo ufw allow 9092
/opt/kafka
├── bin # 启动脚本
├── config # 配置文件
├── logs # 日志
└── libs # 依赖库
如果你需要:
可以告诉我你的使用场景,我可以给你更详细方案。