updated

src/main/java/com/nisum/spark/dem/Consumer/StreamingConsumer.java

@@ -9,9 +9,6 @@ import org.apache.spark.sql.types.StructType;
 
 import java.util.concurrent.TimeoutException;
 
-/**
- * @author Vmuthav
- */
 @Slf4j
 public class StreamingConsumer {
     public static final String MONGODB_DOCUMENT_COLLECTION = "mongodb://127.0.0.1/ProductsDB.product_list_status_shipped";

src/main/java/com/nisum/spark/dem/Producer/StreamingProducer.java

@@ -5,9 +5,6 @@ import org.apache.spark.sql.Dataset;
 import org.apache.spark.sql.Row;
 import org.apache.spark.sql.SparkSession;
 
-/**
- * @author Vmuthav
- */
 @Slf4j
 public class StreamingProducer {
     private static String csvFilePath = "src/main/resources/dataformats/FileToKafka.csv";

src/main/java/com/nisum/spark/dem/ProductInfo/ProductsDto.java

@@ -6,9 +6,6 @@ import lombok.NoArgsConstructor;
 import org.springframework.data.annotation.Id;
 import org.springframework.data.mongodb.core.mapping.Document;
 
-/**
- * @author Vmuthav
- */
 @Data
 @NoArgsConstructor
 @AllArgsConstructor