Skip to content

Commit 7dd34c5

Browse files
committed
Removes deprecated DescribeTopicsResult method
1 parent bfbf3a8 commit 7dd34c5

File tree

1 file changed

+1
-1
lines changed
  • binders/kafka-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/provisioning

1 file changed

+1
-1
lines changed

binders/kafka-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/provisioning/KafkaTopicProvisioner.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -468,7 +468,7 @@ private void createTopicAndPartitions(AdminClient adminClient, final String topi
468468
DescribeTopicsResult describeTopicsResult = adminClient
469469
.describeTopics(Collections.singletonList(topicName));
470470
KafkaFuture<Map<String, TopicDescription>> topicDescriptionsFuture = describeTopicsResult
471-
.all();
471+
.allTopicNames();
472472
Map<String, TopicDescription> topicDescriptions = topicDescriptionsFuture
473473
.get(this.operationTimeout, TimeUnit.SECONDS);
474474
TopicDescription topicDescription = topicDescriptions.get(topicName);

0 commit comments

Comments
 (0)