在 Debian 下配置 Kafka,通常分为 安装 JDK → 下载 Kafka → 配置 → 启动 → 测试 几个步骤。下面给你一个单机版(开发/测试)的清晰流程,如果你要集群版我可以再补。
sudo apt update
sudo apt install -y openjdk-17-jdk
(Kafka 3.x 推荐 JDK 11 / 17)
验证:
java -version
以 Kafka 3.7 为例(可换版本):
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
Kafka 3.x 仍可用 Zookeeper(KRaft 模式可后讲)
编辑:
sudo nano /opt/kafka/config/zookeeper.properties
默认一般够用:
dataDir=/tmp/zookeeper
clientPort=2181
sudo nano /opt/kafka/config/server.properties
关键配置(单机):
broker.id=0
listeners=PLAINTEXT://:9092
advertised.listeners=PLAINTEXT://localhost:9092
log.dirs=/tmp/kafka-logs
zookeeper.connect=localhost:2181
cd /opt/kafka
bin/zookeeper-server-start.sh config/zookeeper.properties
新开一个终端:
cd /opt/kafka
bin/kafka-server-start.sh config/server.properties
看到 started (kafka.server.KafkaServer) 就成功了。
bin/kafka-topics.sh --create \
--topic test \
--bootstrap-server localhost:9092 \
--partitions 1 \
--replication-factor 1
bin/kafka-console-producer.sh \
--topic test \
--bootstrap-server localhost:9092
输入任意内容,回车
新终端:
bin/kafka-console-consumer.sh \
--topic test \
--bootstrap-server localhost:9092 \
--from-beginning
能收到消息 ✅
sudo netstat -tunlp | grep 9092
需要我给你写 kafka.service 和 zookeeper.service 文件也可以。
Kafka 3.x 支持,但配置稍复杂,适合生产。
如果你告诉我:
我可以直接给你 定制版配置 + systemd 自启脚本。