Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-7881

Inter.broker.procol.version is incorrect for Rolling Upgrade

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Critical
    • Resolution: Cannot Reproduce
    • Affects Version/s: 2.1.0
    • Fix Version/s: None
    • Component/s: admin
    • Labels:
      None
    • Flags:
      Important

      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.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                manmedia@gmail.com M. Manna
                Reporter:
                manmedia@gmail.com M. Manna
              • Votes:
                0 Vote for this issue
                Watchers:
                1 Start watching this issue

                Dates

                • Due:
                  Created:
                  Updated:
                  Resolved:

                  Time Tracking

                  Estimated:
                  Original Estimate - 2m
                  2m
                  Remaining:
                  Remaining Estimate - 2m
                  2m
                  Logged:
                  Time Spent - Not Specified
                  Not Specified