From 93cd52d29d8fab0880af8f95237fc2cd61b59b3d Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Tue, 6 Feb 2024 10:06:52 -0500 Subject: [PATCH] KafkaTopicProvisioner - cleanup deprecation --- .../binder/kafka/provisioning/KafkaTopicProvisioner.java | 3 ++- 1 file changed, 2 insertions(+), 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 099c0145f..20cc865a7 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 @@ -642,7 +642,7 @@ public class KafkaTopicProvisioner implements final DescribeTopicsResult describeTopicsResult = adminClient .describeTopics(Collections.singletonList(topicName)); - describeTopicsResult.all().get(); + describeTopicsResult.allTopicNames().get(); } catch (ExecutionException ex) { if (ex.getCause() instanceof UnknownTopicOrPartitionException unknownTopicOrPartitionException) { @@ -654,6 +654,7 @@ public class KafkaTopicProvisioner implements + "). This will affect the health check."); } } + // If we don't have partition information, that is a fatal operation and thus exiting the app. throw new RuntimeException("Failed to obtain partition information for the topic " + topicName); } // do a sanity check on the partition set