diff --git a/kafka-streams/src/main/java/io/micronaut/configuration/kafka/streams/KafkaStreamsFactory.java b/kafka-streams/src/main/java/io/micronaut/configuration/kafka/streams/KafkaStreamsFactory.java index 9189c8b57..0de88ac6f 100644 --- a/kafka-streams/src/main/java/io/micronaut/configuration/kafka/streams/KafkaStreamsFactory.java +++ b/kafka-streams/src/main/java/io/micronaut/configuration/kafka/streams/KafkaStreamsFactory.java @@ -83,6 +83,7 @@ public Map getStreams() { /** * Builds the default {@link KafkaStreams} bean from the configuration and the supplied {@link ConfiguredStreamBuilder}. * + * @param name The configuration name * @param builder The builder * @param kStreams The KStream definitions * @return The {@link KafkaStreams} bean @@ -101,7 +102,7 @@ KafkaStreams kafkaStreams( ); eventPublisher.publishEvent(new BeforeKafkaStreamStart(kafkaStreams, kStreams)); streams.put(kafkaStreams, builder); - if(LOG.isDebugEnabled()) { + if (LOG.isDebugEnabled()) { LOG.debug("Initializing Application {} with topology:\n{}", name, topology.describe().toString()); } kafkaStreams.start();