apache-kafka - Kafka升级：升级时需要指定inter.broker.protocol.version吗？

Question

我将我的 Kafka 集群从以下步骤升级为： 1.1.0https ://kafka.apache.org/documentation/#upgrade_2_3_02.3.0

一切顺利（而且我不必更改消息格式版本）。我完全理解为什么我们应该在第一次滚动重启时将其设置为inter.broker.protocol.version，1.1但我不明白为什么我们应该在之后再次将其设置为2.3value。

我的意思是我们可以从中删除 inter.broker.protocol.version参数server.properties，它应该没问题。为什么2.3经纪人应该知道他们应该使用2.3协议版本，这不是默认的协议吗？

标签： apache-kafka

Answer 1

第一次升级我的 kafka 集群时，我遇到了同样的问题。但是，下次升级时，我不必在安装新的二进制文件之前设置 inter.broker.protocol.version，因为它已经存在。我的想法是它不会伤害任何东西，它消除了关于我登录的任何代理上正在使用什么 inter.broker.protocol.version 的任何问题。