[KAFKA-3827] log.message.format.version should default to inter.broker.protocol.version

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Won't Fix
• Affects Version/s: 0.10.0.0
• Labels: newbie
• Assignee: Manasvi Gupta
• Reporter: Jun Rao
• Created: 12/Jun/16 20:57
• Updated: 10/Apr/18 22:21
• Resolved: 10/Apr/18 22:21

Description

Currently, if one sets inter.broker.protocol.version to 0.9.0 and restarts the broker, one will get the following exception since log.message.format.version defaults to 0.10.0. It will be more intuitive if log.message.format.version defaults to the value of inter.broker.protocol.version.

java.lang.IllegalArgumentException: requirement failed: log.message.format.version 0.10.0-IV1 cannot be used when inter.broker.protocol.version is set to 0.9.0.1
at scala.Predef$.require(Predef.scala:233)
at kafka.server.KafkaConfig.validateValues(KafkaConfig.scala:1023)
at kafka.server.KafkaConfig.<init>(KafkaConfig.scala:994)
at kafka.server.KafkaConfig$.fromProps(KafkaConfig.scala:743)
at kafka.server.KafkaConfig$.fromProps(KafkaConfig.scala:740)
at kafka.server.KafkaServerStartable$.fromProps(KafkaServerStartable.scala:28)
at kafka.Kafka$.main(Kafka.scala:58)
at kafka.Kafka.main(Kafka.scala)