spring/spring-boot
1
0
Fork 0
mirror of https://github.com/spring-projects/spring-boot.git synced 2026-10-10 03:19:01 +00:00
Code Issues Projects Releases Wiki Activity

Suppress Jackson deprecation warnings for Spring Kafka

Browse Source 
See gh-45535
This commit is contained in:
Phillip Webb
2025-08-14 17:00:23 -07:00
parent 094a8610da
commit 42d0f7216b
2 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
documentation/spring-boot-docs/src/main/java/org/springframework/boot/docs/messaging/kafka/streams/MyKafkaStreamsConfiguration.java
+4 -2
View File
@@ -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<Integer, String> kStream(StreamsBuilder streamsBuilder) {
KStream<Integer, String> 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;
}
documentation/spring-boot-docs/src/main/kotlin/org/springframework/boot/docs/messaging/kafka/streams/MyKafkaStreamsConfiguration.kt
+3 -2
View File
@@ -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<Int, String> {
val stream = streamsBuilder.stream<Int, String>("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
}