下面给你一份**在 Debian 上安装并配置 Kafka(单节点示例)**的常见步骤,适合入门和测试环境。生产环境还需要考虑权限、监控、集群等。
sudo apt update
sudo apt upgrade -y
Kafka 3.x 推荐 Java 8 / 11 / 17
sudo apt install -y openjdk-17-jdk
验证:
java -version
以 3.7.0 为例(可自行换版本):
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.3+ 可用 KRaft 模式(无 Zookeeper),下面先给传统方式
cd /opt/kafka
编辑:
vim config/zookeeper.properties
常见配置:
dataDir=/tmp/zookeeper
clientPort=2181
vim config/server.properties
关键项:
broker.id=0
listeners=PLAINTEXT://:9092
advertised.listeners=PLAINTEXT://localhost:9092
log.dirs=/tmp/kafka-logs
zookeeper.connect=localhost:2181
bin/zookeeper-server-start.sh config/zookeeper.properties
(后台运行可加 & 或用 systemd)
bin/kafka-server-start.sh config/server.properties
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 \
--from-beginning \
--bootstrap-server localhost:9092
[Unit]
Description=Apache Kafka
After=network.target
[Service]
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
JAVA_HOME如果你想要:
告诉我你的使用场景,我可以直接给你对应配置。