Made changes to format.

Author: contactsunny

pom.xml

@@ -44,11 +44,13 @@
             <artifactId>kafka-clients</artifactId>
             <version>0.11.0.0</version>
         </dependency>
+
         <dependency>
             <groupId>org.codehaus.jettison</groupId>
             <artifactId>jettison</artifactId>
             <version>1.2</version>
         </dependency>
+
     </dependencies>
 
 </project>

src/main/java/com/contactsunny/poc/SimpleKafkaProducer/SimpleKafkaProducerApplication.java

@@ -40,20 +40,20 @@ public void run(String... args) {
         /*
          * Defining producer properties.
          */
-        Properties props = new Properties();
-        props.put("bootstrap.servers", kafkaBootstrapServers);
-        props.put("acks", "all");
-        props.put("retries", 0);
-        props.put("batch.size", 16384);
-        props.put("linger.ms", 1);
-        props.put("buffer.memory", 33554432);
-        props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
-        props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
+        Properties producerProperties = new Properties();
+        producerProperties.put("bootstrap.servers", kafkaBootstrapServers);
+        producerProperties.put("acks", "all");
+        producerProperties.put("retries", 0);
+        producerProperties.put("batch.size", 16384);
+        producerProperties.put("linger.ms", 1);
+        producerProperties.put("buffer.memory", 33554432);
+        producerProperties.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
+        producerProperties.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
 
         /*
         Creating a Kafka Producer object with the configuration above.
          */
-        KafkaProducer<String, String> producer = new KafkaProducer<>(props);
+        KafkaProducer<String, String> producer = new KafkaProducer<>(producerProperties);
 
         /*
         The sendTestMessagesToKafka method will generate some random test messages
@@ -64,6 +64,7 @@ public void run(String... args) {
         /*
         Now that we've produced some test messages, let's see how to consume them using a Kafka consumer object.
          */
+
         /*
          * Defining Kafka consumer properties.
          */
@@ -108,10 +109,10 @@ public void run(String... args) {
      * @param producer The Kafka producer we created in the run() method earlier.
      */
     private void sendTestMessagesToKafka(KafkaProducer<String, String> producer) {
-    /*
-    Creating a loop which iterates 10 times, from 0 to 9, and sending a
-    simple message to Kafka.
-     */
+        /*
+        Creating a loop which iterates 10 times, from 0 to 9, and sending a
+        simple message to Kafka.
+         */
         for (int index = 0; index < 10; index++) {
             sendKafkaMessage("The index is now: " + index, producer, theTechCheckTopicName);
         }
@@ -164,9 +165,9 @@ private void sendTestMessagesToKafka(KafkaProducer<String, String> producer) {
 
     /**
      * Function to send a message to Kafka
-     * @param payload
-     * @param producer
-     * @param topic
+     * @param payload The String message that we wish to send to the Kafka topic
+     * @param producer The KafkaProducer object
+     * @param topic The topic to which we want to send the message
      */
     private static void sendKafkaMessage(String payload,
              KafkaProducer<String, String> producer,