问题描述
我按照以下步骤将我的Kafka集群从 1.1.0
升级到了 2.3.0
: https://kafka.apache.org/documentation/#upgrade_2_3_0
I upgraded my Kafka cluster from 1.1.0
to 2.3.0
following those steps :https://kafka.apache.org/documentation/#upgrade_2_3_0
一切都很好(而且我不必更改消息格式的版本).我完全理解为什么在第一次滚动重启时我们应该将 inter.broker.protocol.version
设置为 1.1
,但是我不明白为什么我们应该再设置它然后再次设置为 2.3
值.
Everything went fine ( and I did not have to change the message format version).I totally understand why we should set the inter.broker.protocol.version
to 1.1
when doing the first rolling restart, but I don't get why we should then set it again to 2.3
value afterwards.
我的意思是我们只需从 server.properties
中删除 inter.broker.protocol.version
参数,就可以了.为什么 2.3
经纪人应该知道他们应该使用 2.3
协议版本,所以默认情况下这不是该协议吗?
I mean we can just remove the inter.broker.protocol.version
parameter from server.properties
and it should be fine. Why 2.3
brokers should know that they should use 2.3
protocol version, is this not the protocol by default ?
推荐答案
我第一次升级kafka集群时也遇到了同样的问题.但是,下次我升级时,在安装新的二进制文件之前,不必设置inter.broker.protocol.version,因为它已经存在.我的想法是,它不会造成任何伤害,并且消除了有关我登录到的任何代理上正在使用哪个inter.broker.protocol.version的任何疑问.
I had the same question the first time I upgraded my kafka cluster. However the next time I upgraded I didnt have to set the inter.broker.protocol.version before I installed the new binary because it was already there. My thought is that it doesnt hurt anything and it removes any question about what inter.broker.protocol.version is being used on any broker that I am logged on to.
这篇关于Kafka upgrade:升级时需要指定inter.broker.protocol.version吗?的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持!