From 2dd76f7e78bad11206916195f15a81c0f79f9aad Mon Sep 17 00:00:00 2001
From: Amol Gote <aamolgote@hotmail.com>
Date: Sun, 15 Oct 2023 16:01:50 -0400
Subject: [PATCH] Review comment incorporation

---
 .../kafka/message/ordering/ProducerConfigurations.java |  1 +
 .../kafka/message/ordering/payload/Message.java        |  3 ++-
 .../ordering/serialization/JacksonDeserializer.java    | 10 +++++-----
 3 files changed, 8 insertions(+), 6 deletions(-)

diff --git a/apache-kafka-2/src/main/java/com/baeldung/kafka/message/ordering/ProducerConfigurations.java b/apache-kafka-2/src/main/java/com/baeldung/kafka/message/ordering/ProducerConfigurations.java
index 60ae5fc2f8..2c885b7caa 100644
--- a/apache-kafka-2/src/main/java/com/baeldung/kafka/message/ordering/ProducerConfigurations.java
+++ b/apache-kafka-2/src/main/java/com/baeldung/kafka/message/ordering/ProducerConfigurations.java
@@ -1,6 +1,7 @@
 package com.baeldung.kafka.message.ordering;
 
 import org.apache.kafka.clients.producer.KafkaProducer;
+import org.apache.kafka.clients.producer.ProducerConfig;
 import org.apache.kafka.clients.producer.ProducerRecord;
 
 import java.util.Properties;
diff --git a/apache-kafka-2/src/main/java/com/baeldung/kafka/message/ordering/payload/Message.java b/apache-kafka-2/src/main/java/com/baeldung/kafka/message/ordering/payload/Message.java
index 317aec699e..095aeef89a 100644
--- a/apache-kafka-2/src/main/java/com/baeldung/kafka/message/ordering/payload/Message.java
+++ b/apache-kafka-2/src/main/java/com/baeldung/kafka/message/ordering/payload/Message.java
@@ -2,6 +2,7 @@ package com.baeldung.kafka.message.ordering.payload;
 
 import javax.swing.*;
 import java.util.Random;
+import java.util.concurrent.ThreadLocalRandom;
 
 public class Message implements Comparable<Message> {
     private long insertPosition;
@@ -44,7 +45,7 @@ public class Message implements Comparable<Message> {
 
     public static long getRandomMessageId() {
         Random rand = new Random();
-        return rand.nextInt(1000);
+        return ThreadLocalRandom.current().nextInt(1000);
     }
 }
 
diff --git a/apache-kafka-2/src/main/java/com/baeldung/kafka/message/ordering/serialization/JacksonDeserializer.java b/apache-kafka-2/src/main/java/com/baeldung/kafka/message/ordering/serialization/JacksonDeserializer.java
index 34aa181fcb..cb0b77e4c0 100644
--- a/apache-kafka-2/src/main/java/com/baeldung/kafka/message/ordering/serialization/JacksonDeserializer.java
+++ b/apache-kafka-2/src/main/java/com/baeldung/kafka/message/ordering/serialization/JacksonDeserializer.java
@@ -6,10 +6,10 @@ import java.util.Map;
 
 public class JacksonDeserializer<T> implements Deserializer<T> {
     private final ObjectMapper objectMapper = new ObjectMapper();
-    private Class<T> tClass;
+    private Class<T> type;
 
-    public JacksonDeserializer(Class<T> tClass) {
-        this.tClass = tClass;
+    public JacksonDeserializer(Class<T> type) {
+        this.type = type;
     }
 
     public JacksonDeserializer() {
@@ -18,7 +18,7 @@ public class JacksonDeserializer<T> implements Deserializer<T> {
 
     @Override
     public void configure(Map<String, ?> configs, boolean isKey) {
-        this.tClass = (Class<T>) configs.get("value.deserializer.serializedClass");
+        this.type = (Class<T>) configs.get("value.deserializer.serializedClass");
     }
 
     @Override
@@ -27,7 +27,7 @@ public class JacksonDeserializer<T> implements Deserializer<T> {
             return null;
         }
         try {
-            return objectMapper.readValue(bytes, tClass);
+            return objectMapper.readValue(bytes, type);
         } catch (Exception e) {
             throw new RuntimeException("Error deserializing value", e);
         }