fix kafka deployment

redbadger · Dec 11, 2023 · 0c1697e · 0c1697e
1 parent d0dcaaa
commit 0c1697e
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 4 deletions.
diff --git a/notification-service/src/main/resources/application.properties b/notification-service/src/main/resources/application.properties
@@ -11,4 +11,4 @@ spring.kafka.consumer.group-id=notificationId
 spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
 spring.kafka.consumer.value-deserializer=org.springframework.kafka.support.serializer.JsonDeserializer
 spring.kafka.consumer.properties.spring.json.type.mapping=event:com.redbadger.notificationservice.OrderPlacedEvent
-spring.kafka.properties.security.protocol=PLAINTEXT
+spring.kafka.properties.security.protocol=PLAINTEXT
diff --git a/order-service/src/main/java/com/redbadger/orderservice/service/OrderService.java b/order-service/src/main/java/com/redbadger/orderservice/service/OrderService.java
@@ -61,7 +61,8 @@ public String placeOrder(OrderRequest orderRequest) {
             log.info("All requested products are in stock");
             orderRepository.save(order);
             kafkaTemplate.send("notificationTopic", new OrderPlacedEvent(order.getOrderNumber()));
-            return String.format("Order Number %s Placed Successfully", order.getOrderNumber());
+            log.info(String.format("Order Number %s Placed Successfully", order.getOrderNumber()));
+            return "Order Placed";
         }
         else {
             throw new IllegalArgumentException("Product is not in stock, please try again later");

diff --git a/order-service/src/main/resources/application.properties b/order-service/src/main/resources/application.properties
@@ -35,4 +35,4 @@ spring.kafka.template.default-topic=notificationTopic
 spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
 spring.kafka.producer.value-serializer=org.springframework.kafka.support.serializer.JsonSerializer
 spring.kafka.producer.properties.spring.json.type.mapping=event:com.redbadger.orderservice.event.OrderPlacedEvent
-spring.kafka.properties.security.protocol=PLAINTEXT
+spring.kafka.properties.security.protocol=PLAINTEXT
diff --git a/spin_up.sh b/spin_up.sh
@@ -29,7 +29,7 @@ popd
 
 echo "deploying services..."
 cd deployment
-helm install kafka oci://registry-1.docker.io/bitnamicharts/kafka
+helm install kafka oci://registry-1.docker.io/bitnamicharts/kafka --set listeners.client.protocol=PLAINTEXT
 
 for service in *
 do