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"));