Skip to content

Commit b0275f8

Browse files
committed
[strimzi#434] feat: added create topic endpoint - logger edit
Signed-off-by: ilkerkocatepe <[email protected]>
1 parent 58093e6 commit b0275f8

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

src/main/java/io/strimzi/kafka/bridge/KafkaBridgeAdmin.java

+3-3
Original file line numberDiff line numberDiff line change
@@ -93,13 +93,13 @@ public CompletionStage<Set<String>> listTopics() {
9393
* @return a CompletionStage Void
9494
*/
9595
public CompletionStage<Void> createTopic(String topicName) {
96-
log.trace("Create topic thread {}", Thread.currentThread());
97-
log.info("Create topic {}", topicName);
96+
LOGGER.trace("Create topic thread {}", Thread.currentThread());
97+
LOGGER.info("Create topic {}", topicName);
9898
CompletableFuture<Void> promise = new CompletableFuture<>();
9999
this.adminClient.createTopics(Collections.singletonList(new NewTopic(topicName, 2, (short) 1)))
100100
.all()
101101
.whenComplete((topic, exception) -> {
102-
log.trace("Create topic callback thread {}", Thread.currentThread());
102+
LOGGER.trace("Create topic callback thread {}", Thread.currentThread());
103103
if (exception == null) {
104104
promise.complete(topic);
105105
} else {

0 commit comments

Comments
 (0)