Suyash Garg created KAFKA-8649:
----------------------------------
Summary: 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
Fix For: 2.0.0
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
(v7.6.3#76005)
