debian升级Kafka怎么弄

在 Debian 上升级 Kafka，一般分几种情况：apt 安装的 Kafka、官方二进制包安装的 Kafka、以及是否使用 Kafka 集群。下面我按最常见、最稳妥的方式说明。

一、先确认当前 Kafka 安装方式

which kafka-server-start.sh
dpkg -l | grep kafka

• 如果有 /usr/share/kafka 或 /opt/kafka → 官方二进制包
• 如果 dpkg -l 能看到 kafka → apt 安装

二、官方二进制包升级（最常见，推荐）

1️⃣ 停止 Kafka

systemctl stop kafka
# 或
/opt/kafka/bin/kafka-server-stop.sh

⚠️ 先停 Kafka，再停 Zookeeper（如有）

2️⃣ 备份（非常重要）

cp -r /opt/kafka /opt/kafka_backup_$(date +%F)

3️⃣ 下载新版本

去官网： https://kafka.apache.org/downloads

cd /opt
wget https://downloads.apache.org/kafka/3.7.0/kafka_2.13-3.7.0.tgz
tar -xzf kafka_2.13-3.7.0.tgz

4️⃣ 保留配置文件

cp /opt/kafka/config/server.properties \
   /opt/kafka_2.13-3.7.0/config/

如有：

• zookeeper.properties
• producer.properties
• consumer.properties

一并复制

5️⃣ 切换目录

rm -rf /opt/kafka
ln -s /opt/kafka_2.13-3.7.0 /opt/kafka

6️⃣ 启动 Kafka

systemctl start kafka
# 或
/opt/kafka/bin/kafka-server-start.sh -daemon /opt/kafka/config/server.properties

三、APT 安装的 Kafka 升级

apt update
apt list --upgradable | grep kafka
apt upgrade kafka

⚠️ Debian 官方源里的 Kafka 版本通常 很旧，不建议生产用

四、Kafka 跨版本升级注意事项（重点）

✅ 小版本升级（如 3.6 → 3.7）

一般直接升级即可

⚠️ 大版本升级（如 2.x → 3.x）

特别注意：

1. Kafka 3.x 默认不再依赖 Zookeeper（KRaft）
2. 如果是老集群：
   • 先确认 inter.broker.protocol.version
   • 升级后逐步提升版本

示例：

inter.broker.protocol.version=3.6
log.message.format.version=3.6

升级稳定后再改成新版本。

五、升级后验证

/opt/kafka/bin/kafka-topics.sh \
  --bootstrap-server localhost:9092 \
  --list

查看日志：

tail -f /opt/kafka/logs/server.log

六、生产环境建议

• ✅ 滚动升级（一台一台来）
• ✅ 先升级非 controller 节点
• ✅ 保留旧版本包至少 7 天
• ✅ 提前演练回滚

如果你愿意，可以告诉我：

• Kafka 当前版本
• 是否集群
• 是否用 Zookeeper / KRaft
• Debian 版本

我可以给你 精确升级步骤。