version to 4.5.0

Author: DC2-DanielKrueger

README.adoc

@@ -7,7 +7,7 @@
 
 *Type*: Demonstration Customization
 
-*Version*: 4.4.3
+*Version*: 4.5.0
 
 *License*: Apache License Version 2.0
 
@@ -23,7 +23,7 @@ to grasp the core concepts of HiveMQ Kafka customization development.
 
 . Clone this repository into a Java 11 gradle project.
 . Run `./gradlew jar` task from gradle to build the customization.
-. Move the file: "build/libs/hivemq-kafka-hello-world-customization-4.4.3.jar" to the directory: "HIVEMQ_HOME/extensions/hivemq-kafka-extension/customizations"
+. Move the file: "build/libs/hivemq-kafka-hello-world-customization-4.5.0.jar" to the directory: "HIVEMQ_HOME/extensions/hivemq-kafka-extension/customizations"
 . Copy the resources/kafka-configuration.xml to "HIVEMQ_HOME/extensions/hivemq-kafka-extension" and adapt it to your environment.
 . Delete the "HIVEMQ_HOME/extensions/hivemq-kafka-extension/DISABLED" file.
 . Start HiveMQ.

src/main/java/com/hivemq/extensions/kafka/customizations/helloworld/KafkaToMqttHelloWorldTransformer.java

@@ -38,22 +38,22 @@ public class KafkaToMqttHelloWorldTransformer implements KafkaToMqttTransformer
 
     private static final @NotNull Logger log = LoggerFactory.getLogger(KafkaToMqttHelloWorldTransformer.class);
 
-    public final static String MISSING_VALUE_COUNTER_NAME = "com.hivemq.hello-world-example.missing-value.count";
+    public static final @NotNull String MISSING_VALUE_COUNTER_NAME = "com.hivemq.hello-world-example.missing-value.count";
 
     private @Nullable MetricRegistry metricRegistry;
     private @Nullable Counter missingValueCounter;
 
     @Override
-    public void init(@NotNull final KafkaToMqttInitInput input) {
+    public void init(final @NotNull KafkaToMqttInitInput input) {
         this.metricRegistry = input.getMetricRegistry();
         // build any custom metric based on your business logic and needs
         this.missingValueCounter = metricRegistry.counter(MISSING_VALUE_COUNTER_NAME);
     }
 
 
     @Override
-    public void transformKafkaToMqtt(@NotNull final KafkaToMqttInput kafkaToMqttInput,
-                                     @NotNull final KafkaToMqttOutput kafkaToMqttOutput) {
+    public void transformKafkaToMqtt(final @NotNull KafkaToMqttInput kafkaToMqttInput,
+                                     final @NotNull KafkaToMqttOutput kafkaToMqttOutput) {
         // get the Kafka record from the input
         final KafkaRecord kafkaRecord = kafkaToMqttInput.getKafkaRecord();