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: