1.如果是从 2.1.x 之前的版本升级，请参阅下面关于用于存储消费者偏移量的架构更改的说明。将 inter.broker.protocol.version 更改为最新版本后，将无法降级到 2.1 之前的版本。
更新所有代理上的 server.properties 并添加以下属性。 CURRENT_KAFKA_VERSION 是指您要升级的版本。
CURRENT_MESSAGE_FORMAT_VERSION 是指当前使用的消息格式版本。如果之前覆盖了消息格式版本，则应保留其当前值。或者，如果从 0.11.0.x 之前的版本升级，则应设置 CURRENT_MESSAGE_FORMAT_VERSION 以匹配 CURRENT_KAFKA_VERSION。
inter.broker.protocol.version=CURRENT_KAFKA_VERSION (e.g., 2.7, 2.6, etc.)
log.message.format.version=CURRENT_MESSAGE_FORMAT_VERSION
如果是从 0.11.0.x 或更高版本升级，并且您没有覆盖消息格式，那么您只需要覆盖中间代理协议版本。
2.一次升级一个代理：关闭broker，更新代码，然后重新启动。完成此操作后，代理将运行最新版本，您可以验证集群的行为和性能是否符合预期。如果有任何问题，此时仍然可以降级。
3.验证集群的行为和性能后，通过编辑 inter.broker.protocol.version 并将其设置为 2.8 来提升协议版本。
4.一个个重启broker，让新的协议版本生效。一旦broker开始使用最新的协议版本，就无法再将集群降级到旧版本。
5.如果已按照上述说明覆盖了消息格式版本，则需要再进行一次滚动重启以将其升级到最新版本。将所有（或大多数）消费者升级到 0.11.0 或更高版本后，将每个代理上的 log.message.format.version 更改为 2.8 并一一重启。请注意，不再维护的旧 Scala 客户端不支持 0.11 中引入的消息格式，因此为了避免转换成本（或利用恰好一次语义），必须使用较新的 Java 客户端。