From 4024f19119318e85e522fdba80e83702c7202ce9 Mon Sep 17 00:00:00 2001
From: Artem Bilan <artem.bilan@broadcom.com>
Date: Thu, 19 Dec 2024 13:16:24 -0500
Subject: [PATCH] Fix format violation in the `TwitterGeoFunctionConfiguration`

* Resolve TODO in the `DebeziumReactiveConsumerConfiguration`
---
 .../cloud/fn/twitter/geo/TwitterGeoFunctionConfiguration.java | 3 +--
 .../debezium/DebeziumReactiveConsumerConfiguration.java       | 4 +---
 2 files changed, 2 insertions(+), 5 deletions(-)

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<?>, 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/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);