produce and consume from kafka

src/main/java/com/ascendfinalproject/warehouse/Consumer.java

@@ -10,7 +10,7 @@ import java.io.IOException;
 @Service
 public class Consumer {
 
-  private final Logger logger = LoggerFactory.getLogger(Producer.class);
+  private final Logger logger = LoggerFactory.getLogger(Consumer.class);
 
   // this is placeholder
   @KafkaListener(topics = "fulfilled", groupId = "WAREHOUSE_MANAGEMENT")

src/main/resources/application.properties

 spring.data.mongodb.uri=mongodb+srv://warehouse1:ascendWarehouseProject@warehouse-cluster.xopll.mongodb.net/myFirstDatabase?retryWrites=true&w=majority
 spring.data.mongodb.database=test
 
-server: port: 9000
+server:
+  port: 9000
 spring:
     kafka:
         consumer: