From d386ff79237961f5dc65bfcaa133684650be1ca2 Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Mon, 22 Apr 2019 18:53:14 -0400 Subject: [PATCH] Make KeyValueSerdeResolver public Resolves #644 Resolves #645 --- .../streams/KafkaStreamsBinderSupportAutoConfiguration.java | 2 ++ .../stream/binder/kafka/streams/KeyValueSerdeResolver.java | 2 +- 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderSupportAutoConfiguration.java b/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderSupportAutoConfiguration.java index 12da94b08..a56226833 100644 --- a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderSupportAutoConfiguration.java +++ b/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderSupportAutoConfiguration.java @@ -31,6 +31,7 @@ import org.springframework.beans.factory.ObjectProvider; import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.boot.autoconfigure.AutoConfigureAfter; import org.springframework.boot.autoconfigure.condition.ConditionalOnBean; +import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean; import org.springframework.boot.autoconfigure.kafka.KafkaProperties; import org.springframework.boot.context.properties.ConfigurationProperties; import org.springframework.boot.context.properties.EnableConfigurationProperties; @@ -302,6 +303,7 @@ public class KafkaStreamsBinderSupportAutoConfiguration { @Bean @SuppressWarnings("unchecked") + @ConditionalOnMissingBean public KeyValueSerdeResolver keyValueSerdeResolver( @Qualifier("streamConfigGlobalProperties") Object streamConfigGlobalProperties, KafkaStreamsBinderConfigurationProperties properties) { diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KeyValueSerdeResolver.java b/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KeyValueSerdeResolver.java index f0584c2d1..d2e13b31e 100644 --- a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KeyValueSerdeResolver.java +++ b/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KeyValueSerdeResolver.java @@ -53,7 +53,7 @@ import org.springframework.util.StringUtils; * @author Soby Chacko * @author Lei Chen */ -class KeyValueSerdeResolver { +public class KeyValueSerdeResolver { private final Map streamConfigGlobalProperties;