From 69a721216db57353c5a3c9426f62c03dfdc2fb19 Mon Sep 17 00:00:00 2001
From: kimscott <sanaloveyou@uengine.org>
Date: Fri, 22 Nov 2019 16:03:35 +0900
Subject: [PATCH] =?UTF-8?q?=EC=A3=BC=EB=AC=B8=20=EC=B7=A8=EC=86=8C=20?=
 =?UTF-8?q?=EC=9D=B4=EB=B2=A4=ED=8A=B8=20=EB=B0=9C=EC=83=9D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/main/java/com/example/template/ProductService.java | 1 -
 src/main/resources/application.yml                     | 8 ++++++++
 2 files changed, 8 insertions(+), 1 deletion(-)

diff --git a/src/main/java/com/example/template/ProductService.java b/src/main/java/com/example/template/ProductService.java
index 807464d..246c20b 100644
--- a/src/main/java/com/example/template/ProductService.java
+++ b/src/main/java/com/example/template/ProductService.java
@@ -21,7 +21,6 @@ public class ProductService {
     @StreamListener(KafkaProcessor.INPUT)
     public void onOrderPlaced(@Payload String message) {
         System.out.println("##### listener : " + message);
-
         ObjectMapper objectMapper = new ObjectMapper();
         objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
 
diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
index 850162e..93e3ebe 100644
--- a/src/main/resources/application.yml
+++ b/src/main/resources/application.yml
@@ -13,6 +13,14 @@ spring:
   cloud:
     stream:
       kafka:
+#        bindings:
+#          event-in:
+#            consumer:
+#              enableDlq: true
+#              dlqName: JobError
+#              autoCommitOnError: true
+#              autoCommitOffset: true
+#              maxAttempts: 1
         binder:
           brokers: localhost:9092
         streams: