diff --git a/src/main/java/io/github/eocqrs/kafka/yaml/YamlMapParams.java b/src/main/java/io/github/eocqrs/kafka/yaml/YamlMapParams.java index e3629c09..bc77ef75 100644 --- a/src/main/java/io/github/eocqrs/kafka/yaml/YamlMapParams.java +++ b/src/main/java/io/github/eocqrs/kafka/yaml/YamlMapParams.java @@ -36,12 +36,9 @@ /** * This class converts a YAML source from * kebab case keys into kafka specific keys Map. - * - * @param The key type. - * @param The value type. */ @RequiredArgsConstructor -public class YamlMapParams implements Scalar> { +public final class YamlMapParams implements Scalar> { /** * The config value. @@ -78,7 +75,7 @@ public YamlMapParams(final InputStream stream) { } @Override - public final Map value() { + public Map value() { final Map accum = new HashMap<>(0); this.value .forEach( diff --git a/src/test/java/io/github/eocqrs/kafka/yaml/YamlMapParamsTest.java b/src/test/java/io/github/eocqrs/kafka/yaml/YamlMapParamsTest.java index b1935fde..fe38f36e 100644 --- a/src/test/java/io/github/eocqrs/kafka/yaml/YamlMapParamsTest.java +++ b/src/test/java/io/github/eocqrs/kafka/yaml/YamlMapParamsTest.java @@ -46,7 +46,7 @@ final class YamlMapParamsTest { @BeforeEach void setParams() throws Exception { - this.params = new YamlMapParams<>("producer.yaml").value(); + this.params = new YamlMapParams("producer.yaml").value(); } @Test