[strimzi#434] feat: added create topic endpoint - logger edit

Signed-off-by: ilkerkocatepe <[email protected]>
ilkerkocatepe · Nov 19, 2024 · b17bf93 · b17bf93
1 parent 36c2fa0
commit b17bf93
Showing 1 changed file with 3 additions and 3 deletions.
diff --git 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 {