diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/config/MessageConverterHelperConfiguration.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/config/MessageConverterHelperConfiguration.java index 840b1feeb..ce3cc28ea 100644 --- a/binders/kafka-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/config/MessageConverterHelperConfiguration.java +++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/config/MessageConverterHelperConfiguration.java @@ -28,7 +28,7 @@ import org.springframework.context.annotation.Configuration; public class MessageConverterHelperConfiguration { @Bean - public MessageConverterHelper messageConverterHelper() { + public MessageConverterHelper kafkaMessageConverterHelper() { return new DefaultMessageConverterHelper(); } } diff --git a/binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/main/java/org/springframework/cloud/stream/binder/rabbit/config/MessageConverterHelperConfiguration.java b/binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/main/java/org/springframework/cloud/stream/binder/rabbit/config/MessageConverterHelperConfiguration.java index ea1ca65ac..2cf17deea 100644 --- a/binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/main/java/org/springframework/cloud/stream/binder/rabbit/config/MessageConverterHelperConfiguration.java +++ b/binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/main/java/org/springframework/cloud/stream/binder/rabbit/config/MessageConverterHelperConfiguration.java @@ -27,7 +27,7 @@ import org.springframework.context.annotation.Configuration; public class MessageConverterHelperConfiguration { @Bean - public MessageConverterHelper messageConverterHelper() { + public MessageConverterHelper rabbitMessageConverterHelper() { return new DefaultMessageConverterHelper(); } }