CODEWITHSUNDEEP
apache-kafka
Alok Kumar
Alok Kumar

Reputation: 63

How to know whether Kafka was upgraded?

I was trying to upgrade Kafka from 0.8.2.1 to 0.10.2. I followed the following steps:

1.Updated server.properties file on broker and add the following properties: 

 inter.broker.protocol.version=0.8.2
  log.message.format.version=0.8.2

2.Upgrade the brokers one at a time: shut down the broker and restart it.

3.Once the entire cluster is upgraded, bumped the protocol version by editing inter.broker.protocol.version and setting it to 0.10.2.

4.Restarted the brokers one by one for the new protocol version to take effect.

But, I don't think Kafka was upgraded. Is there any way to check the whether Kafka was upgraded successfully or not. Am I missing something in the above steps ?

Upvotes: 1

Views: 3906

Answers (1)

amethystic
amethystic

Reputation: 7089

Firstly, you could check all jar files under kafka/libs to see it they are versioned 0.10.2.

Secondly, start the broker servers, check server.log and search INFO Kafka version : 0.10.2.0

Thirdly, prompt a terminal and try to execute the script below (You definitely got failed to upgrade if there is no such script):

bin/kafka-broker-api-versions.sh --bootstrap-server localhost:9092

And the output should display that current max version for OffsetFetch request is 2 which proves a upgrade success, as shown below:

OffsetFetch(9): 0 to 2 [usable: 2]

Upvotes: 1

Related Questions