MINOR: Add comment about needing to keep wrapping in HashSet
@@ -253,6 +253,9 @@ public class EmbeddedSingleNodeKafkaCluster extends ExternalResource {
@Override
public boolean conditionMet() {
//TODO once KAFKA-6098 is fixed use AdminClient to verify topics have been deleted
+
+ // The Set returned from JavaConverters.setAsJavaSetConverter does not support the remove
+ // method so we need to continue to wrap in a HashSet
final Set<String> allTopics = new HashSet<>(
JavaConverters.setAsJavaSetConverter(broker.kafkaServer().zkClient().getAllTopicsInCluster()).asJava());
return !allTopics.removeAll(deletedTopics);
