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

Reply via email to