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

Error while rolling update from Kafka Streams 2.0.0 -> Kafka Streams 2.1.0

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Critical
    • Resolution: Fixed
    • Affects Version/s: 2.0.0, 2.1.0, 2.2.0, 2.3.0
    • Fix Version/s: 2.0.2, 2.1.2, 2.2.2, 2.4.0, 2.3.1
    • Component/s: streams
    • Labels:
      None

      Description

      While doing a rolling update of a cluster of nodes running Kafka Streams application, the stream threads in the nodes running the old version of the library (2.0.0), fail with the following error: 

      [ERROR] [application-existing-StreamThread-336] [o.a.k.s.p.internals.StreamThread] - stream-thread [application-existing-StreamThread-336] Encountered the following error during processing:
      java.lang.IllegalArgumentException: version must be between 1 and 3; was: 4
      #011at org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfo.<init>(SubscriptionInfo.java:67)
      #011at org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor.subscription(StreamsPartitionAssignor.java:312)
      #011at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.metadata(ConsumerCoordinator.java:176)
      #011at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.sendJoinGroupRequest(AbstractCoordinator.java:515)
      #011at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.initiateJoinGroup(AbstractCoordinator.java:466)
      #011at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.joinGroupIfNeeded(AbstractCoordinator.java:412)
      #011at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:352)
      #011at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:337)
      #011at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:333)
      #011at org.apache.kafka.clients.consumer.KafkaConsumer.updateAssignmentMetadataIfNeeded(KafkaConsumer.java:1218)
      #011at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1175)
      #011at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1154)
      #011at org.apache.kafka.streams.processor.internals.StreamThread.pollRequests(StreamThread.java:861)
      #011at org.apache.kafka.streams.processor.internals.StreamThread.runOnce(StreamThread.java:814)
      #011at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:767)
      #011at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:736)
      

        Attachments

          Activity

            People

            • Assignee:
              ableegoldman Sophie Blee-Goldman
              Reporter:
              ferbncode Suyash Garg
            • Votes:
              0 Vote for this issue
              Watchers:
              5 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: