From 3c3521558b8896e5c41dac6ea25cb3899ca10406 Mon Sep 17 00:00:00 2001
From: sampadawagde <sampada.aws@gmail.com>
Date: Tue, 17 Aug 2021 14:21:04 +0530
Subject: [PATCH] JAVA-6390: review corrections

---
 apache-kafka/pom.xml                                         | 5 ++---
 .../src/main/java/com/baeldung/flink/model/InputMessage.java | 5 ++++-
 2 files changed, 6 insertions(+), 4 deletions(-)

diff --git a/apache-kafka/pom.xml b/apache-kafka/pom.xml
index 41cbab44ed..cda91ed92f 100644
--- a/apache-kafka/pom.xml
+++ b/apache-kafka/pom.xml
@@ -26,12 +26,12 @@
         <dependency>
             <groupId>org.slf4j</groupId>
             <artifactId>slf4j-api</artifactId>
-            <version>${slf4j.version}</version>
+            <version>${org.slf4j.version}</version>
         </dependency>
         <dependency>
             <groupId>org.slf4j</groupId>
             <artifactId>slf4j-log4j12</artifactId>
-            <version>${slf4j.version}</version>
+            <version>${org.slf4j.version}</version>
         </dependency>
         <dependency>
             <groupId>org.apache.flink</groupId>
@@ -165,7 +165,6 @@
 
     <properties>
         <assertj.version>3.6.2</assertj.version>
-        <slf4j.version>1.7.25</slf4j.version>
         <kafka.version>2.8.0</kafka.version>
         <testcontainers-kafka.version>1.15.3</testcontainers-kafka.version>
         <testcontainers-jupiter.version>1.15.3</testcontainers-jupiter.version>
diff --git a/apache-kafka/src/main/java/com/baeldung/flink/model/InputMessage.java b/apache-kafka/src/main/java/com/baeldung/flink/model/InputMessage.java
index 9331811b91..d33eb5a9ac 100644
--- a/apache-kafka/src/main/java/com/baeldung/flink/model/InputMessage.java
+++ b/apache-kafka/src/main/java/com/baeldung/flink/model/InputMessage.java
@@ -61,7 +61,10 @@ public class InputMessage {
         if (o == null || getClass() != o.getClass())
             return false;
         InputMessage message1 = (InputMessage) o;
-        return Objects.equal(sender, message1.sender) && Objects.equal(recipient, message1.recipient) && Objects.equal(sentAt, message1.sentAt) && Objects.equal(message, message1.message);
+        return Objects.equal(sender, message1.sender) && 
+                Objects.equal(recipient, message1.recipient) && 
+                Objects.equal(sentAt, message1.sentAt) && 
+                Objects.equal(message, message1.message);
     }
 
     @Override