Skip to content

Commit b442e09

Browse files
committed
GH-2525: Fix Test
Resumed `TopicPartition` order is indeterminate.
1 parent f3cfa19 commit b442e09

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

spring-kafka/src/test/java/org/springframework/kafka/listener/KafkaMessageListenerContainerTests.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2907,7 +2907,9 @@ public void resumePartitionAfterRevokeAndReAssign() throws Exception {
29072907
suspendConsumerThread.countDown();
29082908
assertThat(resumeLatch.await(10, TimeUnit.SECONDS)).isTrue();
29092909
assertThat(pausedParts).hasSize(0);
2910-
verify(consumer).resume(List.of(tp0, tp1));
2910+
ArgumentCaptor<List<TopicPartition>> resumed = ArgumentCaptor.forClass(List.class);
2911+
verify(consumer).resume(resumed.capture());
2912+
assertThat(resumed.getValue()).contains(tp0, tp1);
29112913
container.stop();
29122914
}
29132915

0 commit comments

Comments
 (0)