我正在尝试将我的kafka群集从kafka 1.0.0升级到kafka 2.0。我停止了群集中的所有示例,并用-
inter.broker.protocol.version=1.0
我正在从1.0.0升级,尚未覆盖消息格式,因此inter.broker.protocol.version是我必须更新的唯一参数。
我重新开始Kafka,但什么也没发生 grep "Kafka version" /usr/local/kafka/logs/*
或者进入libs文件夹,我看到的是1.0.0,而不是2.0,这表明Kafka仍然在1.0.0上运行,有人能告诉我我做错了什么吗?
注意:我将从这里开始执行升级程序https://kafka.apache.org/documentation/#upgrade
暂无答案!
目前还没有任何答案,快来回答吧!