Commit 6389f5b3 authored by lmethuku's avatar lmethuku

kafka consumer

parent 13e15b97
...@@ -16,7 +16,7 @@ public class OrderConsumerService { ...@@ -16,7 +16,7 @@ public class OrderConsumerService {
private OrderRepository orderRepository; private OrderRepository orderRepository;
// Kafka listener to consume messages from the 'order-topic' topic // Kafka listener to consume messages from the 'order-topic' topic
@KafkaListener(topics = "order-topic", groupId = "my-consumer-group"/*, containerFactory = "kafkaListenerContainerFactory"*/) @KafkaListener(topics = "order-topic", groupId = "my-consumer-group", containerFactory = "kafkaListenerContainerFactory")
public void consumeOrder(Order order) { public void consumeOrder(Order order) {
System.out.println("Consumed Order: " + order); System.out.println("Consumed Order: " + order);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment