diff --git a/src/main/java/com/example/template/OrderService.java b/src/main/java/com/example/template/OrderService.java index 202c04a..85b9631 100644 --- a/src/main/java/com/example/template/OrderService.java +++ b/src/main/java/com/example/template/OrderService.java @@ -27,6 +27,7 @@ public class OrderService { /** * 상품 변경이 발생할때마다, 상품정보를 저장해 놓음 */ + @StreamListener(KafkaProcessor.INPUT) public void onProductChanged(@Payload String message) { System.out.println("##### listener : " + message);