diff --git a/extensions/kafka-streams/runtime/src/main/java/io/quarkus/kafka/streams/runtime/KafkaStreamsProducer.java b/extensions/kafka-streams/runtime/src/main/java/io/quarkus/kafka/streams/runtime/KafkaStreamsProducer.java index 01920dd6fc377..11f7ff429fb96 100644 --- a/extensions/kafka-streams/runtime/src/main/java/io/quarkus/kafka/streams/runtime/KafkaStreamsProducer.java +++ b/extensions/kafka-streams/runtime/src/main/java/io/quarkus/kafka/streams/runtime/KafkaStreamsProducer.java @@ -77,7 +77,7 @@ public KafkaStreamsProducer(KafkaStreamsSupport kafkaStreamsSupport, KafkaStream shutdown = false; // No producer for Topology -> nothing to do if (topology.isUnsatisfied()) { - LOGGER.debug("No Topology producer; Kafka Streams will not be started"); + LOGGER.warn("No Topology producer; Kafka Streams will not be started"); this.executorService = null; this.kafkaStreams = null; this.kafkaStreamsTopologyManager = null;