From 576ca1185fd01913125d192d67f9745d6e419d40 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Fri, 4 Nov 2022 14:07:29 +0100 Subject: [PATCH] WIP --- src/main/java/de/juplo/kafka/SimpleConsumer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/de/juplo/kafka/SimpleConsumer.java b/src/main/java/de/juplo/kafka/SimpleConsumer.java index 53bd112..0e37686 100644 --- a/src/main/java/de/juplo/kafka/SimpleConsumer.java +++ b/src/main/java/de/juplo/kafka/SimpleConsumer.java @@ -27,7 +27,7 @@ public class SimpleConsumer implements Runnable { try { - log.info("{} - Subscribing to topic test", id); + log.info("{} - Subscribing to topic {}", id, topic); consumer.subscribe(Arrays.asList(topic)); while (true) -- 2.20.1