From 42d0f7216bf01ac5082aae1af2c9c706618d219e Mon Sep 17 00:00:00 2001 From: Phillip Webb Date: Thu, 14 Aug 2025 17:00:23 -0700 Subject: [PATCH] Suppress Jackson deprecation warnings for Spring Kafka See gh-45535 --- .../kafka/streams/MyKafkaStreamsConfiguration.java | 6 ++++-- .../messaging/kafka/streams/MyKafkaStreamsConfiguration.kt | 5 +++-- 2 files changed, 7 insertions(+), 4 deletions(-) diff --git a/documentation/spring-boot-docs/src/main/java/org/springframework/boot/docs/messaging/kafka/streams/MyKafkaStreamsConfiguration.java b/documentation/spring-boot-docs/src/main/java/org/springframework/boot/docs/messaging/kafka/streams/MyKafkaStreamsConfiguration.java index c47f962e782..fd3d99909e9 100644 --- a/documentation/spring-boot-docs/src/main/java/org/springframework/boot/docs/messaging/kafka/streams/MyKafkaStreamsConfiguration.java +++ b/documentation/spring-boot-docs/src/main/java/org/springframework/boot/docs/messaging/kafka/streams/MyKafkaStreamsConfiguration.java @@ -27,16 +27,18 @@ import org.apache.kafka.streams.kstream.Produced; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.kafka.annotation.EnableKafkaStreams; -import org.springframework.kafka.support.serializer.JsonSerde; @Configuration(proxyBeanMethods = false) @EnableKafkaStreams public class MyKafkaStreamsConfiguration { @Bean + @SuppressWarnings("removal") public KStream kStream(StreamsBuilder streamsBuilder) { KStream stream = streamsBuilder.stream("ks1In"); - stream.map(this::uppercaseValue).to("ks1Out", Produced.with(Serdes.Integer(), new JsonSerde<>())); + stream.map(this::uppercaseValue) + .to("ks1Out", + Produced.with(Serdes.Integer(), new org.springframework.kafka.support.serializer.JsonSerde<>())); return stream; } diff --git a/documentation/spring-boot-docs/src/main/kotlin/org/springframework/boot/docs/messaging/kafka/streams/MyKafkaStreamsConfiguration.kt b/documentation/spring-boot-docs/src/main/kotlin/org/springframework/boot/docs/messaging/kafka/streams/MyKafkaStreamsConfiguration.kt index 4e6b8fc9295..0b569339bb2 100644 --- a/documentation/spring-boot-docs/src/main/kotlin/org/springframework/boot/docs/messaging/kafka/streams/MyKafkaStreamsConfiguration.kt +++ b/documentation/spring-boot-docs/src/main/kotlin/org/springframework/boot/docs/messaging/kafka/streams/MyKafkaStreamsConfiguration.kt @@ -24,7 +24,6 @@ import org.apache.kafka.streams.kstream.Produced import org.springframework.context.annotation.Bean import org.springframework.context.annotation.Configuration import org.springframework.kafka.annotation.EnableKafkaStreams -import org.springframework.kafka.support.serializer.JsonSerde @Suppress("UNUSED_PARAMETER") @Configuration(proxyBeanMethods = false) @@ -32,9 +31,11 @@ import org.springframework.kafka.support.serializer.JsonSerde class MyKafkaStreamsConfiguration { @Bean + @Suppress("DEPRECATION") fun kStream(streamsBuilder: StreamsBuilder): KStream { val stream = streamsBuilder.stream("ks1In") - stream.map(this::uppercaseValue).to("ks1Out", Produced.with(Serdes.Integer(), JsonSerde())) + stream.map(this::uppercaseValue).to("ks1Out", Produced.with(Serdes.Integer(), + org.springframework.kafka.support.serializer.JsonSerde())) return stream }