我正试图将我的Kafka集群从Kafka 1.0.0升级到Kafka 2.0我停止了集群中的所有实例,并用更新了server.properties文件-
inter.broker.protocol.version=1.0
我正在从1.0.0升级,但尚未覆盖消息格式,因此inter.broker.protocol.version是唯一需要更新的参数。
我重新启动了卡夫卡但是当我重新启动的时候 grep "Kafka version" /usr/local/kafka/logs/* 或者进入libs文件夹,我看到的是1.0.0,而不是2.0,这表明卡夫卡仍然在1.0.0上运行,有人能告诉我我做错了什么吗?
grep "Kafka version" /usr/local/kafka/logs/*
注:我从这里开始执行升级程序 https://kafka.apache.org/documentation/#upgrade