Support Questions
Find answers, ask questions, and share your expertise

log.message.format.version in Kafka

Contributor

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

1 ACCEPTED SOLUTION

Mentor

@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

View solution in original post

2 REPLIES 2

Mentor

@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

Contributor

@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

Take a Tour of the Community
Don't have an account?
Your experience may be limited. Sign in to explore more.