Details
Critical 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)