diff --git a/bid/src/main/java/com/berry/bid/application/model/event/PostEvent.java b/bid/src/main/java/com/berry/bid/application/model/event/PostEvent.java index b45e4c41..ea8c3a14 100644 --- a/bid/src/main/java/com/berry/bid/application/model/event/PostEvent.java +++ b/bid/src/main/java/com/berry/bid/application/model/event/PostEvent.java @@ -21,7 +21,7 @@ public static class Update{ private Long postId; private Long writerId; private String status; - private Integer ImmediatePrice; + private Integer immediatePrice; private Integer startedPrice; } diff --git a/bid/src/main/java/com/berry/bid/infrastructure/config/KafkaConsumerConfig.java b/bid/src/main/java/com/berry/bid/infrastructure/config/KafkaConsumerConfig.java index f19def56..ddb2f53d 100644 --- a/bid/src/main/java/com/berry/bid/infrastructure/config/KafkaConsumerConfig.java +++ b/bid/src/main/java/com/berry/bid/infrastructure/config/KafkaConsumerConfig.java @@ -40,6 +40,7 @@ public static Map kafkaListenerConfig(String kafkaPort,Strin configProps.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, JsonDeserializer.class); configProps.put(JsonDeserializer.TRUSTED_PACKAGES, "*"); configProps.put(JsonDeserializer.VALUE_DEFAULT_TYPE, listenedClass); + configProps.put(JsonDeserializer.USE_TYPE_INFO_HEADERS, false); return configProps; } diff --git a/post/src/main/java/com/berry/post/application/model/event/PostEvent.java b/post/src/main/java/com/berry/post/application/model/event/PostEvent.java index 3bc011dd..9d5ef1b0 100644 --- a/post/src/main/java/com/berry/post/application/model/event/PostEvent.java +++ b/post/src/main/java/com/berry/post/application/model/event/PostEvent.java @@ -13,13 +13,13 @@ public class PostEvent { @NoArgsConstructor(access = AccessLevel.PUBLIC) public static class Status { private Long postId; - private ProductStatus status; + private String status; private Long writerId; private Integer startedPrice; - private Integer ImmediatePrice; + private Integer immediatePrice; public static Status from(Post post) { - return new Status(post.getId(), post.getProductStatus(), post.getWriterId(), post.getStartedPrice(), post.getImmediatePrice()); + return new Status(post.getId(), post.getProductStatus().name(), post.getWriterId(), post.getStartedPrice(), post.getImmediatePrice()); } }