log.message.format.version in Kafka

[#1]

Hi,

1. What is log.message.format.version in Kafka

2. What is the use of log.message.format.version in Kafka

3.What could be the version of log.message.format

Thanks,

Nilesh

[#2 · Accepted solution]

@Nilesh

1. What is log.message.format.version in Kafka

This translates to your current kafka version or the value of inter.broker.protocol.version 

2. What is the use of log.message.format.version in Kafka

 It can be used for rolling restart during upgrade it also specifies format version the broker will use to append messages to the logs.Setting it incorrectly will cause consumers with older versions to break as they will receive messages with a format that they don't understand. 

3.What could be the version of log.message.format

This should be/ or translate to your current kafka version eg (0.10.0, 0.10.1, 0.10.2, 0.11.0). 

These 2 parameters should be the same.

inter.broker.protocol.version=CURRENT_KAFKA_VERSION 
log.message.format.version=CURRENT_MESSAGE_FORMAT_VERSION 

Hope that helps

[#3]

@Geoffrey Shelton Okot

Thank you for your reply. I have some following queries,

1. What is inter.broker.protocol.version and what it does.

2. How log.message.format and inter.broker.protocol relate each other.

3. Could you please explain in detail the use of log.message.format.version.

4. When and on what basis need to the change log.message.format and inter.broker.protocol version.

5. What changes are required on consumer and producer side after changed the version.

Thanks,

Nilesh