Fixing checkstyle errors

micronaut-projects · Mar 14, 2021 · a3b48d1 · a3b48d1
1 parent bc3b7c2
commit a3b48d1
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...a-streams/src/main/java/io/micronaut/configuration/kafka/streams/KafkaStreamsFactory.java b/...a-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();