Skip to content

Commit 2525fbb

Browse files
authored
Replace usage of deprecated DescribeTopicsResult method (#290)
1 parent c24056f commit 2525fbb

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/main/java/io/vertx/kafka/admin/impl/KafkaAdminClientImpl.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -98,7 +98,7 @@ public Future<Map<String, TopicDescription>> describeTopics(List<String> topicNa
9898
Promise<Map<String, TopicDescription>> promise = ctx.promise();
9999

100100
DescribeTopicsResult describeTopicsResult = this.adminClient.describeTopics(topicNames);
101-
describeTopicsResult.all().whenComplete((t, ex) -> {
101+
describeTopicsResult.allTopicNames().whenComplete((t, ex) -> {
102102
if (ex == null) {
103103

104104
Map<String, TopicDescription> topics = new HashMap<>();
@@ -145,7 +145,7 @@ public Future<Map<String, TopicDescription>> describeTopics(List<String> topicNa
145145
Promise<Map<String, TopicDescription>> promise = ctx.promise();
146146

147147
DescribeTopicsResult describeTopicsResult = this.adminClient.describeTopics(topicNames, Helper.to(options));
148-
describeTopicsResult.all().whenComplete((t, ex) -> {
148+
describeTopicsResult.allTopicNames().whenComplete((t, ex) -> {
149149
if (ex == null) {
150150

151151
Map<String, TopicDescription> topics = new HashMap<>();

0 commit comments

Comments
 (0)