[
https://issues.apache.org/jira/browse/KAFKA-7881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
M. Manna updated KAFKA-7881:
----------------------------
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.
was:
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.
> 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
> Priority: Critical
> Original Estimate: 2m
> Remaining Estimate: 2m
>
> 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.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
