diff --git a/build.gradle b/build.gradle index 51162ba..f7793e4 100644 --- a/build.gradle +++ b/build.gradle @@ -1,5 +1,5 @@ plugins { - id 'org.springframework.boot' version '3.5.11' + id 'org.springframework.boot' version '4.0.3' id 'io.spring.dependency-management' version '1.1.7' id 'java' id "au.com.dius.pact" version "4.6.20" diff --git a/src/main/java/io/pactflow/example/kafka/KafkaConfiguration.java b/src/main/java/io/pactflow/example/kafka/KafkaConfiguration.java index 1f4f9c0..b3403a8 100644 --- a/src/main/java/io/pactflow/example/kafka/KafkaConfiguration.java +++ b/src/main/java/io/pactflow/example/kafka/KafkaConfiguration.java @@ -11,8 +11,7 @@ import org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory; import org.springframework.kafka.core.ConsumerFactory; import org.springframework.kafka.core.DefaultKafkaConsumerFactory; -import org.springframework.kafka.support.serializer.JsonDeserializer; -import org.springframework.kafka.support.serializer.JsonSerializer; +import org.springframework.kafka.support.serializer.JacksonJsonDeserializer; @EnableKafka @Configuration @@ -24,8 +23,8 @@ public ConsumerFactory productConsumerFactory() { props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092"); props.put(ConsumerConfig.GROUP_ID_CONFIG, "products_group"); props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class); - props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, JsonSerializer.class); - return new DefaultKafkaConsumerFactory<>(props, new StringDeserializer(), new JsonDeserializer<>(Product.class)); + props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, JacksonJsonDeserializer.class); + return new DefaultKafkaConsumerFactory<>(props, new StringDeserializer(), new JacksonJsonDeserializer<>(Product.class)); } @Bean diff --git a/src/test/java/io/pactflow/example/kafka/ProductsPactTest.java b/src/test/java/io/pactflow/example/kafka/ProductsPactTest.java index ecf121c..5ef31c5 100644 --- a/src/test/java/io/pactflow/example/kafka/ProductsPactTest.java +++ b/src/test/java/io/pactflow/example/kafka/ProductsPactTest.java @@ -18,7 +18,7 @@ import java.util.List; import java.util.Map; -import com.fasterxml.jackson.databind.ObjectMapper; +import tools.jackson.databind.ObjectMapper; import static org.junit.jupiter.api.Assertions.assertDoesNotThrow;