Kafka在Debian上如何更新

在 Debian 上更新 Kafka，通常不是通过 apt，而是手动下载新版本并替换。下面给你一套稳妥、常用的更新流程（适用于生产环境）。

一、明确几点（很重要）

1. Kafka 不在 Debian 官方仓库

   • Debian 没有 apt install kafka
   • 更新 = 下载新 tarball + 迁移配置

2. Kafka 依赖 Zookeeper 或 KRaft

   • 更新 Kafka 不一定需要更新 Zookeeper
   • 但版本兼容性要注意

3. 优先看官方升级文档

   • https://kafka.apache.org/documentation/#upgrade

二、升级前准备（强烈建议）

1️⃣ 查看当前版本

kafka-topics.sh --version
# 或
/path/to/kafka/bin/kafka-server-start.sh --version

2️⃣ 备份

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

3️⃣ 查看版本升级跨度

⚠️ 跨多个大版本（如 2.8 → 3.6）必须逐步升级

三、标准升级步骤（推荐）

1️⃣ 下载新版本 Kafka

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

Scala 版本（2.13）一般不用改，除非你项目强依赖

2️⃣ 迁移配置文件

cp /opt/kafka_backup/config/server.properties /opt/kafka_2.13-3.6.1/config/
cp /opt/kafka_backup/config/zookeeper.properties /opt/kafka_2.13-3.6.1/config/

⚠️ 不要直接覆盖整个 config 目录

3️⃣ 停止旧 Kafka

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

确认进程已停：

ps aux | grep kafka

4️⃣ 切换软链接（推荐做法）

ln -sfn /opt/kafka_2.13-3.6.1 /opt/kafka

或更新 systemd 中的路径。

5️⃣ 启动新 Kafka

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

6️⃣ 验证

kafka-topics.sh --bootstrap-server localhost:9092 --list

四、如果是 KRaft 模式（无 Zookeeper）

/opt/kafka/bin/kafka-storage.sh format \
  -t $(uuidgen) \
  -c /opt/kafka/config/kraft/server.properties

⚠️ KRaft 升级步骤更复杂，建议先看官方文档

五、常见错误 & 注意事项

❌ 直接覆盖旧目录

✅ 应保留旧版本，方便回滚

❌ 忽略 protocol.version

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

升级后建议逐步更新。

六、回滚方案（保命）

ln -sfn /opt/kafka_backup /opt/kafka
systemctl restart kafka

七、我可以帮你更精确

你可以直接告诉我：

1. Debian 版本（11 / 12？）
2. Kafka 当前版本
3. 使用 Zookeeper 还是 KRaft
4. 是否生产环境

我可以给你精确到命令级别的升级方案（包括 systemd 配置）。