add correct topic namesfor ordermanagement and warehouse

src/main/java/com/nisum/ascend/inventory/configuration/KafkaConfig.java

-package com.nisum.ascend.inventory.configuration;
-
-import lombok.Value;
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-
-@Configuration
-public class KafkaConfig {
-
-}

src/main/java/com/nisum/ascend/inventory/service/ProductService.java

@@ -43,6 +43,7 @@ public class ProductService {
         if (status.equals("CANCELLED")) {
             stock *= -1;
         } else if (status.equals("RECEIVED")) {
+            System.out.printf("sku = %s, status = %s, itemquanity = %d, stock = %d, finalStock = %d \n", sku, status, itemQuantity);
             return productRepository.findBySku(sku)
                     .flatMap(dbProduct -> {
                         dbProduct.setBlockedStock(dbProduct.getBlockedStock() + itemQuantity);

src/main/resources/application.properties

@@ -6,5 +6,5 @@ spring.data.mongodb.database=products-promotions-DB
 kafka.consumer.acks=all
 kafka.consumer.bootstrap-servers=localhost:9092
 kafka.consumer.group-id=PRODUCT
-kafka.WAREHOUSETOPIC.input=my-messages
-kafka.ORDERTOPIC.input=order-topic
+kafka.WAREHOUSETOPIC.input=WMOS_ORDER_UPDATE
+kafka.ORDERTOPIC.input=OMS_ORDER_UPDATE