你是想问 Debian 下 Kafka 如何安装/配置/启动 吧?下面给你一个从零开始的实操流程(以 Kafka 3.x + Debian 11/12 为例,使用官方二进制包,最常用、最稳妥)。
sudo apt update
sudo apt install -y openjdk-17-jdk
java -version
Kafka 3.x 推荐 Java 11 / 17
sudo mkdir -p /opt/kafka
cd /opt/kafka
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/* .
rm -rf kafka_2.13-3.7.0 kafka_2.13-3.7.0.tgz
vi config/server.properties
常用关键配置:
broker.id=0
listeners=PLAINTEXT://0.0.0.0:9092
advertised.listeners=PLAINTEXT://<服务器IP>:9092
log.dirs=/opt/kafka/logs
zookeeper.connect=localhost:2181
如果是 Kafka 3.3+ 且用 KRaft(无 ZooKeeper),配置方式不同,可告诉我你是否需要。
bin/zookeeper-server-start.sh config/zookeeper.properties
另开终端:
bin/kafka-server-start.sh config/server.properties
sudo vi /etc/systemd/system/zookeeper.service
[Unit]
Description=ZooKeeper
After=network.target
[Service]
Type=simple
User=root
ExecStart=/opt/kafka/bin/zookeeper-server-start.sh /opt/kafka/config/zookeeper.properties
Restart=on-failure
[Install]
WantedBy=multi-user.target
sudo vi /etc/systemd/system/kafka.service
[Unit]
Description=Kafka
After=zookeeper.service
[Service]
Type=simple
User=root
ExecStart=/opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/server.properties
Restart=on-failure
[Install]
WantedBy=multi-user.target
sudo systemctl daemon-reload
sudo systemctl enable --now zookeeper
sudo systemctl enable --now kafka
bin/kafka-topics.sh --create \
--topic test \
--bootstrap-server localhost:9092 \
--partitions 1 \
--replication-factor 1
bin/kafka-topics.sh --list --bootstrap-server localhost:9092
如果你能告诉我:
我可以直接给你定制版配置。