From afb1f79975ac97a476cd97645871183ecec2ac6d Mon Sep 17 00:00:00 2001
From: Otavio Rodolfo Piske <opiske@redhat.com>
Date: Fri, 15 Jan 2021 14:47:10 +0100
Subject: [PATCH] (chores) Cleanup topic deletion code and allow public access
 to the admin client

---
 .../common/clients/kafka/KafkaClient.java             | 11 +++++++----
 1 file changed, 7 insertions(+), 4 deletions(-)

diff --git a/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/clients/kafka/KafkaClient.java b/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/clients/kafka/KafkaClient.java
index 4830843d32..4e335665cb 100644
--- a/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/clients/kafka/KafkaClient.java
+++ b/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/clients/kafka/KafkaClient.java
@@ -20,7 +20,6 @@
 import java.time.Duration;
 import java.util.Collections;
 import java.util.Map;
-import java.util.Properties;
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.Future;
 import java.util.function.Consumer;
@@ -156,14 +155,18 @@ public void produce(String topic, V message, Map<String, String> headers) throws
         future.get();
     }
 
+    public AdminClient getAdminClient() {
+        return AdminClient.create(producerPropertyFactory.getProperties());
+    }
+
     /**
      * Delete a topic
      *
      * @param topic the topic to be deleted
      */
     public void deleteTopic(String topic) {
-        Properties props = producerPropertyFactory.getProperties();
-        AdminClient admClient = AdminClient.create(props);
-        admClient.deleteTopics(Collections.singleton(topic));
+        AdminClient adminClient = getAdminClient();
+
+        adminClient.deleteTopics(Collections.singleton(topic));
     }
 }