在 Debian 上启动 Kafka 服务,通常有两种方式:直接运行(适合测试)和系统服务方式(适合长期使用)。下面分别说明。
Kafka 依赖 Java(推荐 JDK 8 或以上):
sudo apt update
sudo apt install -y default-jdk
java -version
以 Kafka 3.x 为例:
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
cd /opt/kafka
bin/zookeeper-server-start.sh config/zookeeper.properties
Kafka 3.3+ 可使用 KRaft 模式(无需 Zookeeper),但默认仍常用 Zookeeper。
另开一个终端:
cd /opt/kafka
bin/kafka-server-start.sh config/server.properties
看到 started (kafka.server.KafkaServer) 即启动成功。
sudo nano /etc/systemd/system/zookeeper.service
内容:
[Unit]
Description=Apache Zookeeper
After=network.target
[Service]
Type=simple
User=root
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
User=root
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 enable zookeeper
sudo systemctl enable kafka
sudo systemctl start zookeeper
sudo systemctl start kafka
sudo systemctl status kafka
journalctl -u kafka -f
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
config/server.properties 或 JVM 参数如果你告诉我:
我可以给你更精确的启动方式。