[
https://issues.apache.org/jira/browse/KAFKA-7881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
M. Manna resolved KAFKA-7881.
-----------------------------
Resolution: Cannot Reproduce
Assignee: M. Manna
Duplicate jars were present - a delete and copy of new jars resolved the issue.
closing this.
> 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
> Assignee: 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)
