주문 취소 이벤트 발생
This commit is contained in:
@@ -28,7 +28,6 @@ public class OrderService {
|
|||||||
@StreamListener(KafkaProcessor.INPUT)
|
@StreamListener(KafkaProcessor.INPUT)
|
||||||
public void onProductChanged(@Payload String message) {
|
public void onProductChanged(@Payload String message) {
|
||||||
System.out.println("##### listener : " + message);
|
System.out.println("##### listener : " + message);
|
||||||
|
|
||||||
ObjectMapper objectMapper = new ObjectMapper();
|
ObjectMapper objectMapper = new ObjectMapper();
|
||||||
objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
|
objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user