下面分**“安装 + 基础配置 + 启动”**三部分,说明如何在 Debian 上部署 Apache Kafka(单机示例,适合学习/测试;生产环境需 ZooKeeper/KRaft 集群)。
sudo apt update
sudo apt upgrade -y
sudo apt install -y openjdk-17-jdk
java -version
Kafka 2.8+ 支持 KRaft(无 ZooKeeper),下面以 Kafka 3.x + KRaft 为例(推荐)
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
KAFKA_CLUSTER_ID=$(bin/kafka-storage.sh random-uuid)
echo $KAFKA_CLUSTER_ID
nano config/kraft/server.properties
关键配置示例:
node.id=1
controller.quorum.voters=1@localhost:9093
listeners=PLAINTEXT://:9092
advertised.listeners=PLAINTEXT://localhost:9092
log.dirs=/tmp/kafka-logs
bin/kafka-storage.sh format \
-t $KAFKA_CLUSTER_ID \
-c config/kraft/server.properties
bin/kafka-server-start.sh config/kraft/server.properties
nohup bin/kafka-server-start.sh config/kraft/server.properties > kafka.log 2>&1 &
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
# 生产
bin/kafka-console-producer.sh \
--topic test --bootstrap-server localhost:9092
# 消费
bin/kafka-console-consumer.sh \
--topic test --from-beginning --bootstrap-server localhost:9092
如需要我也可以帮你写:
systemd 服务文件只要告诉我你的 使用场景(学习 / 生产 / 云服务器)。