BAEL3889 - Adding braces in EvenOddPartitioner

Chirag Dewan · Chirag Dewan · commit de8acfd6e02a · 2020-06-07T15:29:59.000+05:30
diff --git a/libraries-data-2/src/main/java/com/baeldung/kafka/producer/EvenOddPartitioner.java b/libraries-data-2/src/main/java/com/baeldung/kafka/producer/EvenOddPartitioner.java
@@ -1,4 +1,4 @@
-package com.baeldung.kafka;
+package com.baeldung.kafka.producer;
 
 import org.apache.kafka.clients.producer.internals.DefaultPartitioner;
 import org.apache.kafka.common.Cluster;
@@ -8,8 +8,9 @@ public class EvenOddPartitioner extends DefaultPartitioner {
     @Override
     public int partition(String topic, Object key, byte[] keyBytes, Object value, byte[] valueBytes, Cluster cluster) {
 
-        if (((String)key).length() % 2 == 0)
+        if (((String) key).length() % 2 == 0) {
             return 0;
+        }
 
         return 1;
     }
diff --git a/libraries-data-2/src/main/java/com/baeldung/kafka/producer/KafkaProducer.java b/libraries-data-2/src/main/java/com/baeldung/kafka/producer/KafkaProducer.java
@@ -1,4 +1,4 @@
-package com.baeldung.kafka;
+package com.baeldung.kafka.producer;
 
 import org.apache.kafka.clients.producer.Producer;
 import org.apache.kafka.clients.producer.ProducerRecord;
diff --git a/libraries-data-2/src/test/java/com/baeldung/kafka/producer/KafkaProducerUnitTest.java b/libraries-data-2/src/test/java/com/baeldung/kafka/producer/KafkaProducerUnitTest.java
@@ -1,5 +1,7 @@
-package com.baeldung.kafka;
+package com.baeldung.kafka.producer;
 
+import com.baeldung.kafka.producer.EvenOddPartitioner;
+import com.baeldung.kafka.producer.KafkaProducer;
 import org.apache.kafka.clients.producer.MockProducer;
 import org.apache.kafka.clients.producer.RecordMetadata;
 import org.apache.kafka.common.Cluster;

Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,4 @@`
`1`		`-package com.baeldung.kafka;`
	`1`	`+package com.baeldung.kafka.producer;`
`2`	`2`
`3`	`3`	`import org.apache.kafka.clients.producer.Producer;`
`4`	`4`	`import org.apache.kafka.clients.producer.ProducerRecord;`