Hi All,
I have three zookeepers, two Kafka brokers and some clients (consumer and producer) with current version 0.8.0, according to Kafka document, I do a rolling upgrade to 0.10.0.0 following below procedure: 1) Upgrade zookeeper one by one (shut down, update the code with 0.10.0.0, and restart it) 2) Add following properties into server.properties file of brokers: inter.broker.protocol.version=0.8.0 log.message.format.version=0.8.0 3) Upgrade the first broker (shut down the broker, update the code with 0.10.0.0, and restart it) 4) Upgrade the second broker 5) After all the brokers started, set inter.broker.protocol.version=0.10.0.0 of all the brokers. 6) Restart the brokers one by one 7) Upgrade all the clients one by one 8) Set log.message.format.version =0.10.0.0 of all the brokers. 9) Restart the brokers one by one After restart the first broder (new version) then shut down the second broker (old version) by step 4, the producer could not send message successfully (could not find new message from kafka log), if there is any mistake of my procedure? Thanks! By the way, the message could be sent successfully under below situation, once I shutdown the second broker (old version), the message could not send. 1) Both first broker (new version) and second broker (old version) are launched 2) Only shutdown first broker (new version) 3) Only shutdown second broker while both brokers have old verson Best Regards Johnny