在 Debian 上“升级 Kafka 版本”通常不是用 apt 升级(Debian 官方源里的 Kafka 往往很旧),而是手动替换二进制包。下面按常见场景给你一套稳妥做法。
# Kafka 安装位置(常见)
ls /opt/kafka
ls /usr/local/kafka
# 当前版本
/opt/kafka/bin/kafka-topics.sh --version
cp -r /opt/kafka /opt/kafka_bak_$(date +%F)
以 3.6.1 为例:
cd /opt
wget https://downloads.apache.org/kafka/3.6.1/kafka_2.13-3.6.1.tgz
tar -xzf kafka_2.13-3.6.1.tgz
# 如果你用 systemd
systemctl stop kafka
systemctl stop zookeeper # 如果用内置 ZK
# 或手动
/opt/kafka/bin/kafka-server-stop.sh
⚠️ 不要删 data 目录
mv /opt/kafka /opt/kafka_old
ln -s /opt/kafka_2.13-3.6.1 /opt/kafka
cp -r /opt/kafka_old/config /opt/kafka/conf
重点检查:
server.propertieszookeeper.propertiesconsumer.propertiesproducer.properties常见变化:
listenerslog.dirszookeeper.connectsystemctl start kafka
# 或
/opt/kafka/bin/kafka-server-start.sh -daemon /opt/kafka/config/server.properties
/opt/kafka/bin/kafka-topics.sh --version
/opt/kafka/bin/kafka-topics.sh --list --bootstrap-server localhost:9092
✅ 用滚动升级:
apt show kafka
⚠️ 版本通常极旧,不建议生产用
如果你愿意,可以告诉我:
我可以直接给你精确升级命令。