M. Manna created KAFKA-7881:
-------------------------------
Summary: Inter.broker.procol.version is incorrect for Rolling
Upgrade
Key: KAFKA-7881
URL: https://issues.apache.org/jira/browse/KAFKA-7881
Project: Kafka
Issue Type: Bug
Components: admin
Affects Versions: 2.1.0
Reporter: M. Manna
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.
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.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
