From a526bab311e2b49c1faaee7c8772da53340c14ba Mon Sep 17 00:00:00 2001
From: Deyan Yurukov <deyan.yurukov@gmail.com>
Date: Sat, 26 Apr 2025 23:53:38 +0300
Subject: [PATCH] Removes deprecated DescribeTopicsResult method

Signed-off-by: Deyan Yurukov <deyan.yurukov@gmail.com>
Resolves #3111
---
 .../stream/binder/kafka/provisioning/KafkaTopicProvisioner.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/provisioning/KafkaTopicProvisioner.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/provisioning/KafkaTopicProvisioner.java
index 66c55d024..1cf6fb60c 100644
--- a/binders/kafka-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/provisioning/KafkaTopicProvisioner.java
+++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/provisioning/KafkaTopicProvisioner.java
@@ -468,7 +468,7 @@ public class KafkaTopicProvisioner implements
 			DescribeTopicsResult describeTopicsResult = adminClient
 					.describeTopics(Collections.singletonList(topicName));
 			KafkaFuture<Map<String, TopicDescription>> topicDescriptionsFuture = describeTopicsResult
-					.all();
+					.allTopicNames();
 			Map<String, TopicDescription> topicDescriptions = topicDescriptionsFuture
 					.get(this.operationTimeout, TimeUnit.SECONDS);
 			TopicDescription topicDescription = topicDescriptions.get(topicName);