From ccd2960e39df283e06322a93e6de0310a90e61a3 Mon Sep 17 00:00:00 2001 From: "copilot-swe-agent[bot]" <198982749+Copilot@users.noreply.github.com> Date: Wed, 4 Mar 2026 00:38:20 +0000 Subject: [PATCH 1/2] Initial plan From a17c97b345c9da061f4eaaf6c3f1fb5e0c44dd24 Mon Sep 17 00:00:00 2001 From: "copilot-swe-agent[bot]" <198982749+Copilot@users.noreply.github.com> Date: Wed, 4 Mar 2026 00:47:43 +0000 Subject: [PATCH 2/2] fix: migrate from deprecated Jackson 2 Spring Kafka serializers to Jackson 3 Co-authored-by: JP-Ellis <3196162+JP-Ellis@users.noreply.github.com> --- .../java/io/pactflow/example/kafka/KafkaConfiguration.java | 7 +++---- .../java/io/pactflow/example/kafka/ProductsPactTest.java | 2 +- 2 files changed, 4 insertions(+), 5 deletions(-) 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;