From a3b48d13ce65b35e5f5a334cb12a1cbf6a8baac9 Mon Sep 17 00:00:00 2001
From: Steve Skrla <steve.skrla@gmail.com>
Date: Sun, 14 Mar 2021 11:27:24 -0500
Subject: [PATCH] Fixing checkstyle errors

---
 .../configuration/kafka/streams/KafkaStreamsFactory.java       | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

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<KafkaStreams, ConfiguredStreamBuilder> 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();