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

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

Agile BoardAttach filesAttach ScreenshotVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Critical
    • Resolution: Cannot Reproduce
    • 2.1.0
    • None
    • admin
    • None
    • 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

          This comment will be Viewable by All Users Viewable by All Users
          Cancel

          People

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

            Dates

              Created:
              Updated:
              Resolved:

              Time Tracking

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

              Slack

                Issue deployment