From cb26411070d9fd6b67703ed5c662444f7f1073cb Mon Sep 17 00:00:00 2001
From: lee-soo-heon <sooheon45@uengine.org>
Date: Mon, 28 Oct 2019 13:41:50 +0900
Subject: [PATCH] merge

---
 src/main/java/com/example/template/OrderService.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/java/com/example/template/OrderService.java b/src/main/java/com/example/template/OrderService.java
index f18a6ae..adb8906 100644
--- a/src/main/java/com/example/template/OrderService.java
+++ b/src/main/java/com/example/template/OrderService.java
@@ -25,7 +25,7 @@ public class OrderService {
     /**
      * 상품 변경이 발생할때마다, 상품정보를 저장해 놓음
      */
-    @KafkaListener(topics = "${eventTopic}")
+    @KafkaListener(topics = "${eventTopic}", groupId = "{{policy}}")
     public void onDeliveryCompleted(@Payload String message, ConsumerRecord<?, ?> consumerRecord) {
         System.out.println("##### listener : " + message);