apply fix to upgrade test assignor

apache · Nov 1, 2019 · 71abf9d · 71abf9d
1 parent 7b1865a
commit 71abf9d
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/streams/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java b/streams/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java
@@ -195,7 +195,6 @@ public void onAssignment(final ConsumerPartitionAssignor.Assignment assignment,
             if (maybeUpdateSubscriptionVersion(usedVersion, info.commonlySupportedVersion())) {
                 setAssignmentErrorCode(AssignorError.VERSION_PROBING.code());
                 usedSubscriptionMetadataVersionPeek.set(usedSubscriptionMetadataVersion);
-                return;
             }
 
             final List<TopicPartition> partitions = new ArrayList<>(assignment.partitions());