[KAFKA-7881] Inter.broker.procol.version is incorrect for Rolling Upgrade

• Type: Bug
• Status: Resolved
• Priority: Critical
• Resolution: Cannot Reproduce
• Affects Version/s: 2.1.0
• Component/s: admin
• Flags: Important
• Assignee: M. Manna
• Reporter: M. Manna
• Due: 30/Jan/19
• Created: 29/Jan/19 12:25
• Updated: 29/Jan/19 13:02
• Resolved: 29/Jan/19 13:02

Description

We are getting the following error when upgrading from 1.1.0 to 2.1.0. We have not changed the log message format version.

 

https://kafka.apache.org/21/documentation.html

 

Jan 29 06:06:14 one-drive-loc-01 systemd[1]: Started Zookeeper unit for this machine.
Jan 29 06:06:15 one-drive-loc-01 kafka-server-start.sh[15881]: [2019-01-29 06:06:15,272] INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControl
Jan 29 06:06:15 one-drive-loc-01 kafka-server-start.sh[15881]: [2019-01-29 06:06:15,599] ERROR Exiting Kafka due to fatal exception (kafka.Kafka$)
Jan 29 06:06:15 one-drive-loc-01 kafka-server-start.sh[15881]: java.lang.IllegalArgumentException: Version `2.1` is not a valid version
Jan 29 06:06:15 one-drive-loc-01 kafka-server-start.sh[15881]:         at kafka.api.ApiVersion$$anonfun$apply$1.apply(ApiVersion.scala:88)
Jan 29 06:06:15 one-drive-loc-01 kafka-server-start.sh[15881]:         at kafka.api.ApiVersion$$anonfun$apply$1.apply(ApiVersion.scala:88)
Jan 29 06:06:15 one-drive-loc-01 kafka-server-start.sh[15881]:         at scala.collection.MapLike$class.getOrElse(MapLike.scala:128)
Jan 29 06:06:15 one-drive-loc-01 kafka-server-start.sh[15881]:         at scala.collection.AbstractMap.getOrElse(Map.scala:59)
Jan 29 06:06:15 one-drive-loc-01 kafka-server-start.sh[15881]:         at kafka.api.ApiVersion$.apply(ApiVersion.scala:88)
Jan 29 06:06:15 one-drive-loc-01 kafka-server-start.sh[15881]:         at kafka.server.KafkaConfig.<init>(KafkaConfig.scala:1127)
Jan 29 06:06:15 one-drive-loc-01 kafka-server-start.sh[15881]:         at kafka.server.KafkaConfig.<init>(KafkaConfig.scala:989)
Jan 29 06:06:15 one-drive-loc-01 kafka-server-start.sh[15881]:         at kafka.server.KafkaConfig$.fromProps(KafkaConfig.scala:969)
Jan 29 06:06:15 one-drive-loc-01 kafka-server-start.sh[15881]:         at kafka.server.KafkaServerStartable$.fromProps(KafkaServerStartable.scala:28)
Jan 29 06:06:15 one-drive-loc-01 kafka-server-start.sh[15881]:         at kafka.Kafka$.main(Kafka.scala:82)
Jan 29 06:06:15 one-drive-loc-01 kafka-server-start.sh[15881]:         at kafka.Kafka.main(Kafka.scala)

 

we have also tried to make it to 2.1 but no change. If the version map is being keyed using shortVersion, shouldn't it match? This is the first time we are upgrading (from 1.1.0) and we have never had to change log message format.

Please advise.

Issue Links

• is related to: KAFKA-6238 Issues with protocol version when applying a rolling upgrade to 1.0.0