We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent f3cfa19 commit b442e09Copy full SHA for b442e09
spring-kafka/src/test/java/org/springframework/kafka/listener/KafkaMessageListenerContainerTests.java
@@ -2907,7 +2907,9 @@ public void resumePartitionAfterRevokeAndReAssign() throws Exception {
2907
suspendConsumerThread.countDown();
2908
assertThat(resumeLatch.await(10, TimeUnit.SECONDS)).isTrue();
2909
assertThat(pausedParts).hasSize(0);
2910
- verify(consumer).resume(List.of(tp0, tp1));
+ ArgumentCaptor<List<TopicPartition>> resumed = ArgumentCaptor.forClass(List.class);
2911
+ verify(consumer).resume(resumed.capture());
2912
+ assertThat(resumed.getValue()).contains(tp0, tp1);
2913
container.stop();
2914
}
2915
0 commit comments