Support Questions
Find answers, ask questions, and share your expertise
Announcements
Alert: Welcome to the Unified Cloudera Community. Former HCC members be sure to read and learn how to activate your account here.

log.message.format.version in Kafka

Solved Go to solution

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

Accepted Solutions

Re: log.message.format.version in Kafka

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

2 REPLIES 2

Re: log.message.format.version in Kafka

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

Highlighted

Re: log.message.format.version in Kafka

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

Don't have an account?
Coming from Hortonworks? Activate your account here