From 96309c46fec7b44cd87ca8cf9ce2726255e4f4e8 Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Mon, 30 Oct 2023 16:09:03 -0400 Subject: [PATCH] GH-214: Fix bean name for MappingsProvider Fixes https://github.com/spring-cloud/spring-cloud-stream-binder-aws-kinesis/issues/214 The `ExtendedBindingHandlerMappingsProviderConfiguration` uses a `kafka` prefix for `MappingsProvider` by mistake --- .../ExtendedBindingHandlerMappingsProviderConfiguration.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/spring-cloud-stream-binder-kinesis/src/main/java/org/springframework/cloud/stream/binder/kinesis/config/ExtendedBindingHandlerMappingsProviderConfiguration.java b/spring-cloud-stream-binder-kinesis/src/main/java/org/springframework/cloud/stream/binder/kinesis/config/ExtendedBindingHandlerMappingsProviderConfiguration.java index aadf029..9637b9e 100644 --- a/spring-cloud-stream-binder-kinesis/src/main/java/org/springframework/cloud/stream/binder/kinesis/config/ExtendedBindingHandlerMappingsProviderConfiguration.java +++ b/spring-cloud-stream-binder-kinesis/src/main/java/org/springframework/cloud/stream/binder/kinesis/config/ExtendedBindingHandlerMappingsProviderConfiguration.java @@ -33,7 +33,7 @@ import org.springframework.context.annotation.Configuration; public class ExtendedBindingHandlerMappingsProviderConfiguration { @Bean - public MappingsProvider kafkaExtendedPropertiesDefaultMappingsProvider() { + public MappingsProvider kinesisExtendedPropertiesDefaultMappingsProvider() { return () -> Map.of(ConfigurationPropertyName.of("spring.cloud.stream.kinesis.bindings"), ConfigurationPropertyName.of("spring.cloud.stream.kinesis.default"));