diff --git a/binders/pulsar-binder/spring-cloud-stream-binder-pulsar/src/main/java/org/springframework/cloud/stream/binder/pulsar/config/ExtendedBindingHandlerMappingsProviderConfiguration.java b/binders/pulsar-binder/spring-cloud-stream-binder-pulsar/src/main/java/org/springframework/cloud/stream/binder/pulsar/config/ExtendedBindingHandlerMappingsProviderConfiguration.java index b24426079..24ab676dd 100644 --- a/binders/pulsar-binder/spring-cloud-stream-binder-pulsar/src/main/java/org/springframework/cloud/stream/binder/pulsar/config/ExtendedBindingHandlerMappingsProviderConfiguration.java +++ b/binders/pulsar-binder/spring-cloud-stream-binder-pulsar/src/main/java/org/springframework/cloud/stream/binder/pulsar/config/ExtendedBindingHandlerMappingsProviderConfiguration.java @@ -16,7 +16,6 @@ package org.springframework.cloud.stream.binder.pulsar.config; -import java.util.HashMap; import java.util.Map; import org.springframework.boot.autoconfigure.EnableAutoConfiguration; @@ -37,12 +36,8 @@ public class ExtendedBindingHandlerMappingsProviderConfiguration { @Bean public BindingHandlerAdvise.MappingsProvider pulsarExtendedPropertiesDefaultMappingsProvider() { - return () -> { - Map mappings = new HashMap<>(); - mappings.put( + return () -> Map.of( ConfigurationPropertyName.of("spring.cloud.stream.pulsar.bindings"), ConfigurationPropertyName.of("spring.cloud.stream.pulsar.default")); - return mappings; - }; } }