Skip to content

Commit 42d0f72

Browse files
committed
Suppress Jackson deprecation warnings for Spring Kafka
See gh-45535
1 parent 094a861 commit 42d0f72

File tree

2 files changed

+7
-4
lines changed

2 files changed

+7
-4
lines changed

documentation/spring-boot-docs/src/main/java/org/springframework/boot/docs/messaging/kafka/streams/MyKafkaStreamsConfiguration.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -27,16 +27,18 @@
2727
import org.springframework.context.annotation.Bean;
2828
import org.springframework.context.annotation.Configuration;
2929
import org.springframework.kafka.annotation.EnableKafkaStreams;
30-
import org.springframework.kafka.support.serializer.JsonSerde;
3130

3231
@Configuration(proxyBeanMethods = false)
3332
@EnableKafkaStreams
3433
public class MyKafkaStreamsConfiguration {
3534

3635
@Bean
36+
@SuppressWarnings("removal")
3737
public KStream<Integer, String> kStream(StreamsBuilder streamsBuilder) {
3838
KStream<Integer, String> stream = streamsBuilder.stream("ks1In");
39-
stream.map(this::uppercaseValue).to("ks1Out", Produced.with(Serdes.Integer(), new JsonSerde<>()));
39+
stream.map(this::uppercaseValue)
40+
.to("ks1Out",
41+
Produced.with(Serdes.Integer(), new org.springframework.kafka.support.serializer.JsonSerde<>()));
4042
return stream;
4143
}
4244

documentation/spring-boot-docs/src/main/kotlin/org/springframework/boot/docs/messaging/kafka/streams/MyKafkaStreamsConfiguration.kt

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -24,17 +24,18 @@ import org.apache.kafka.streams.kstream.Produced
2424
import org.springframework.context.annotation.Bean
2525
import org.springframework.context.annotation.Configuration
2626
import org.springframework.kafka.annotation.EnableKafkaStreams
27-
import org.springframework.kafka.support.serializer.JsonSerde
2827

2928
@Suppress("UNUSED_PARAMETER")
3029
@Configuration(proxyBeanMethods = false)
3130
@EnableKafkaStreams
3231
class MyKafkaStreamsConfiguration {
3332

3433
@Bean
34+
@Suppress("DEPRECATION")
3535
fun kStream(streamsBuilder: StreamsBuilder): KStream<Int, String> {
3636
val stream = streamsBuilder.stream<Int, String>("ks1In")
37-
stream.map(this::uppercaseValue).to("ks1Out", Produced.with(Serdes.Integer(), JsonSerde()))
37+
stream.map(this::uppercaseValue).to("ks1Out", Produced.with(Serdes.Integer(),
38+
org.springframework.kafka.support.serializer.JsonSerde()))
3839
return stream
3940
}
4041

0 commit comments

Comments
 (0)