You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "M. Manna (JIRA)" <ji...@apache.org> on 2019/01/29 12:26:00 UTC
[jira] [Created] (KAFKA-7881) Inter.broker.procol.version is
incorrect for Rolling Upgrade
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)