[ https://issues.apache.org/jira/browse/KAFKA-8649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Sophie Blee-Goldman resolved KAFKA-8649. ---------------------------------------- Fix Version/s: 2.3.1 2.4.0 Resolution: Fixed > Error while rolling update from Kafka Streams 2.0.0 -> Kafka Streams 2.1.0 > -------------------------------------------------------------------------- > > Key: KAFKA-8649 > URL: https://issues.apache.org/jira/browse/KAFKA-8649 > Project: Kafka > Issue Type: Bug > Components: streams > Affects Versions: 2.0.0 > Reporter: Suyash Garg > Assignee: Sophie Blee-Goldman > Priority: Critical > Fix For: 2.0.2, 2.1.2, 2.2.2, 2.4.0, 2.3.1 > > > 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: > {code:java} > [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) > {code} -- This message was sent by Atlassian Jira (v8.3.4#803005)