diff --git a/function/spring-twitter-function/src/main/java/org/springframework/cloud/fn/twitter/geo/TwitterGeoFunctionConfiguration.java b/function/spring-twitter-function/src/main/java/org/springframework/cloud/fn/twitter/geo/TwitterGeoFunctionConfiguration.java index 78d92eb9..7afcc812 100644 --- a/function/spring-twitter-function/src/main/java/org/springframework/cloud/fn/twitter/geo/TwitterGeoFunctionConfiguration.java +++ b/function/spring-twitter-function/src/main/java/org/springframework/cloud/fn/twitter/geo/TwitterGeoFunctionConfiguration.java @@ -107,8 +107,7 @@ public class TwitterGeoFunctionConfiguration { @Bean public Function, Message> twitterGeoFunction( Function, GeoQuery> messageToGeoQueryFunction, - Function> twitterPlacesFunction, - Function> managedJson) { + Function> twitterPlacesFunction, Function> managedJson) { return messageToGeoQueryFunction.andThen(twitterPlacesFunction).andThen(managedJson); } diff --git a/supplier/spring-debezium-supplier/src/main/java/org/springframework/cloud/fn/supplier/debezium/DebeziumReactiveConsumerConfiguration.java b/supplier/spring-debezium-supplier/src/main/java/org/springframework/cloud/fn/supplier/debezium/DebeziumReactiveConsumerConfiguration.java index 012caab7..44fa2cd2 100644 --- a/supplier/spring-debezium-supplier/src/main/java/org/springframework/cloud/fn/supplier/debezium/DebeziumReactiveConsumerConfiguration.java +++ b/supplier/spring-debezium-supplier/src/main/java/org/springframework/cloud/fn/supplier/debezium/DebeziumReactiveConsumerConfiguration.java @@ -59,9 +59,7 @@ public class DebeziumReactiveConsumerConfiguration { DebeziumMessageProducerSpec debeziumMessageProducerSpec = Debezium.inboundChannelAdapter(debeziumEngineBuilder) .enableEmptyPayload(supplierProperties.isEnableEmptyPayload()) - .headerNames(supplierProperties.getHeaderNamesToMap()) - // TODO until Spring Integration 6.3.0-M2 - .autoStartup(false); + .headerNames(supplierProperties.getHeaderNamesToMap()); if (debeziumMessageProducerSpecComponentCustomizer != null) { debeziumMessageProducerSpecComponentCustomizer.customize(debeziumMessageProducerSpec);