Fix type ambiguity of method argument in test

sjvanrossum · sjvanrossum · commit 5a6750a4362c · 2026-07-13T23:50:48.000+02:00
diff --git a/it/kafka/src/test/java/org/apache/beam/it/kafka/KafkaResourceManagerTest.java b/it/kafka/src/test/java/org/apache/beam/it/kafka/KafkaResourceManagerTest.java
@@ -166,7 +166,8 @@ public void testCleanupShouldDropNonStaticTopic() throws IOException {
     KafkaResourceManager tm = new KafkaResourceManager(kafkaClient, container, builder);
 
     tm.cleanupAll();
-    verify(kafkaClient).deleteTopics(argThat(list -> list.size() == numTopics));
+    verify(kafkaClient)
+        .deleteTopics(argThat((Collection<String> list) -> list.size() == numTopics));
   }
 
   @Test

Original file line number	Diff line number	Diff line change
`@@ -166,7 +166,8 @@ public void testCleanupShouldDropNonStaticTopic() throws IOException {`
`166`	`166`	`KafkaResourceManager tm = new KafkaResourceManager(kafkaClient, container, builder);`
`167`	`167`
`168`	`168`	`tm.cleanupAll();`
`169`		`- verify(kafkaClient).deleteTopics(argThat(list -> list.size() == numTopics));`
	`169`	`+ verify(kafkaClient)`
	`170`	`+ .deleteTopics(argThat((Collection<String> list) -> list.size() == numTopics));`
`170`	`171`	`}`
`171`	`172`
`172`	`173`	`@Test`