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

["Manasvi Gupta (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/KAFKA-3827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Manasvi Gupta reassigned KAFKA-3827:
------------------------------------

    Assignee: Manasvi Gupta

> 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)