参考官方1.1升级手册：https://kafka.apache.org/11/documentation.html

升级步骤：

1、实时写入并消费数据（用kafka提供的脚本生产和消费数据），保持 __consumer_offsets 高可用（多副本，比如3）

2、修改 server.properties ，添加以下属性，设置为要升级的版本

  • inter.broker.protocol.version=0.10.1
  • log.message.format.version=0.10.1

2、滚动重启broker

3、下载1.1版本源码，将inter.broker.protocol.version和log.message.format.version更新为1.1

  • inter.broker.protocol.version=1.1
  • log.message.format.version=1.1

4、滚动重启broker，观察实时写入并消费数据是否正常，如正常，则表示kafka升级成功。