From baa7a4c9a8b9dd0d20abb99fc5ae961b2e88bcf4 Mon Sep 17 00:00:00 2001
From: ilkerkocatepe <kocatepeilker@gmail.com>
Date: Sat, 7 Sep 2024 22:47:04 +0300
Subject: [PATCH] [#434] feat: added create topic endpoint - logger edit

Signed-off-by: ilkerkocatepe <kocatepeilker@gmail.com>
---
 src/main/java/io/strimzi/kafka/bridge/KafkaBridgeAdmin.java | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/main/java/io/strimzi/kafka/bridge/KafkaBridgeAdmin.java b/src/main/java/io/strimzi/kafka/bridge/KafkaBridgeAdmin.java
index 0de7966c..6f1ed062 100644
--- a/src/main/java/io/strimzi/kafka/bridge/KafkaBridgeAdmin.java
+++ b/src/main/java/io/strimzi/kafka/bridge/KafkaBridgeAdmin.java
@@ -93,13 +93,13 @@ public CompletionStage<Set<String>> listTopics() {
      * @return a CompletionStage Void
      */
     public CompletionStage<Void> createTopic(String topicName) {
-        log.trace("Create topic thread {}", Thread.currentThread());
-        log.info("Create topic {}", topicName);
+        LOGGER.trace("Create topic thread {}", Thread.currentThread());
+        LOGGER.info("Create topic {}", topicName);
         CompletableFuture<Void> promise = new CompletableFuture<>();
         this.adminClient.createTopics(Collections.singletonList(new NewTopic(topicName, 2, (short) 1)))
                 .all()
                 .whenComplete((topic, exception) -> {
-                    log.trace("Create topic callback thread {}", Thread.currentThread());
+                    LOGGER.trace("Create topic callback thread {}", Thread.currentThread());
                     if (exception == null) {
                         promise.complete(topic);
                     } else {