[
https://issues.apache.org/jira/browse/KAFKA-3827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15370702#comment-15370702
]
Mickael Maison commented on KAFKA-3827:
---------------------------------------
The docs still only mention changing log.message.format.version as a
recommendation, see:
https://github.com/apache/kafka/blob/trunk/docs/upgrade.html#L40-L41. As far as
I can tell, this is not only recommended but actually required.
Also if I understand correctly, the only point of keeping
log.message.format.version to an older version after having changed
inter.broker.protocol.version is for performance. Older clients would otherwise
require the brokers to "transform" the messages from the logs.
Does this only affect messages received after the upgrade or new messages as
well ?
Has this cost been estimated for a 0.9->0.10 upgrade ?
Thanks
> log.message.format.version should default to inter.broker.protocol.version
> --------------------------------------------------------------------------
>
> Key: KAFKA-3827
> URL: https://issues.apache.org/jira/browse/KAFKA-3827
> Project: Kafka
> Issue Type: Improvement
> Affects Versions: 0.10.0.0
> Reporter: Jun Rao
> Assignee: Manasvi Gupta
> Labels: newbie
>
> 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)
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
