Fixed compile errors with replacements for deprecations

spring-cloud · Aug 5, 2024 · 42c4210 · 42c4210
1 parent 3dd4a07
commit 42c4210
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 5 deletions.
diff --git a/...ava/org/springframework/cloud/stream/binder/kafka/provisioning/KafkaTopicProvisioner.java b/...ava/org/springframework/cloud/stream/binder/kafka/provisioning/KafkaTopicProvisioner.java
@@ -141,7 +141,7 @@ public KafkaTopicProvisioner(
 
 		Assert.isTrue(kafkaProperties != null, "KafkaProperties cannot be null");
 		this.configurationProperties = kafkaBinderConfigurationProperties;
-		this.adminClientProperties = kafkaProperties.buildAdminProperties();
+		this.adminClientProperties = kafkaProperties.buildAdminProperties(null);
 		normalalizeBootPropsWithBinder(this.adminClientProperties, kafkaProperties,
 			kafkaBinderConfigurationProperties);
 		// If the application provides AdminConfig customizers

diff --git a/.../springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderHealthIndicator.java b/.../springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderHealthIndicator.java
@@ -93,9 +93,9 @@ public class KafkaStreamsBinderHealthIndicator extends AbstractHealthIndicator i
 									KafkaProperties kafkaProperties,
 									KafkaStreamsBindingInformationCatalogue kafkaStreamsBindingInformationCatalogue) {
 		super("Kafka-streams health check failed");
-		kafkaProperties.buildAdminProperties();
+		kafkaProperties.buildAdminProperties(null);
 		this.configurationProperties = kafkaStreamsBinderConfigurationProperties;
-		this.adminClientProperties = kafkaProperties.buildAdminProperties();
+		this.adminClientProperties = kafkaProperties.buildAdminProperties(null);
 		KafkaTopicProvisioner.normalalizeBootPropsWithBinder(this.adminClientProperties, kafkaProperties,
 				kafkaStreamsBinderConfigurationProperties);
 		this.kafkaStreamsRegistry = kafkaStreamsRegistry;

diff --git a/...amework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderSupportAutoConfiguration.java b/...amework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderSupportAutoConfiguration.java
@@ -170,7 +170,7 @@ public KafkaStreamsConfiguration kafkaStreamsConfiguration(
 			@Qualifier("binderConfigurationProperties") KafkaStreamsBinderConfigurationProperties properties,
 			Environment environment) {
 		KafkaProperties kafkaProperties = properties.getKafkaProperties();
-		Map<String, Object> streamsProperties = kafkaProperties.buildStreamsProperties();
+		Map<String, Object> streamsProperties = kafkaProperties.buildStreamsProperties(null);
 		if (kafkaProperties.getStreams().getApplicationId() == null) {
 			String applicationName = environment.getProperty("spring.application.name");
 			if (applicationName != null) {

diff --git a/...abbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/RabbitBinderTests.java b/...abbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/RabbitBinderTests.java
@@ -944,7 +944,7 @@ void producerProperties(TestInfo testInfo) throws Exception {
 				this.rabbitTestSupport.getResource())
 						.receive("foo.props.0.prodPropsRequired-0", 10_000);
 		assertThat(received).isNotNull();
-		assertThat(received.getMessageProperties().getReceivedDelay()).isEqualTo(42);
+		assertThat(received.getMessageProperties().getReceivedDelayLong()).isEqualTo(42);
 
 		producerBinding.unbind();
 		assertThat(endpoint.isRunning()).isFalse();