주문 취소 이벤트 발생

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);
 

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: