Fix format violation in the TwitterGeoFunctionConfiguration

* Resolve TODO in the `DebeziumReactiveConsumerConfiguration`
spring-cloud · Dec 19, 2024 · 4024f19 · 4024f19
1 parent c597124
commit 4024f19
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 5 deletions.
diff --git a/...c/main/java/org/springframework/cloud/fn/twitter/geo/TwitterGeoFunctionConfiguration.java b/...c/main/java/org/springframework/cloud/fn/twitter/geo/TwitterGeoFunctionConfiguration.java
@@ -107,8 +107,7 @@ public Function<GeoQuery, List<Place>> twitterReverseGeocodeFunction(Twitter twi
 	@Bean
 	public Function<Message<?>, Message<byte[]>> twitterGeoFunction(
 			Function<Message<?>, GeoQuery> messageToGeoQueryFunction,
-			Function<GeoQuery, List<Place>> twitterPlacesFunction,
-			Function<Object, Message<byte[]>> managedJson) {
+			Function<GeoQuery, List<Place>> twitterPlacesFunction, Function<Object, Message<byte[]>> managedJson) {
 
 		return messageToGeoQueryFunction.andThen(twitterPlacesFunction).andThen(managedJson);
 	}

diff --git a/...org/springframework/cloud/fn/supplier/debezium/DebeziumReactiveConsumerConfiguration.java b/...org/springframework/cloud/fn/supplier/debezium/DebeziumReactiveConsumerConfiguration.java
@@ -59,9 +59,7 @@ public Publisher<Message<byte[]>> debeziumPublisher(Builder<ChangeEvent<byte[],
 
 		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);