.gitignore

.mvn/wrapper/maven-wrapper.jar

.mvn/wrapper/maven-wrapper.properties

mvnw

mvnw.cmd

pom.xml

...ava/com/spark/kafka/mongo/SparkKafkaMongoApplication.java

...a/com/spark/kafka/mongo/controller/ProductController.java

src/main/java/com/spark/kafka/mongo/entity/Product.java

...ava/com/spark/kafka/mongo/service/SparkKafkaProducer.java

...n/java/com/spark/kafka/mongo/util/SparkMongoConsumer.java

src/main/resources/application.properties

src/main/resources/application.yaml

src/main/resources/products.csv

...om/spark/kafka/mongo/SparkKafkaMongoApplicationTests.java