Fix deprecation

fd4s · Mar 9, 2022 · d5a1b5f · d5a1b5f
1 parent 5bc9a7e
commit d5a1b5f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/modules/core/src/main/scala/fs2/kafka/KafkaAdminClient.scala b/modules/core/src/main/scala/fs2/kafka/KafkaAdminClient.scala
@@ -313,7 +313,7 @@ object KafkaAdminClient {
     withAdminClient: WithAdminClient[F],
     topics: G[String]
   )(implicit G: Foldable[G]): F[Map[String, TopicDescription]] =
-    withAdminClient(_.describeTopics(topics.asJava).all.map(_.toMap))
+    withAdminClient(_.describeTopics(topics.asJava).allTopicNames.map(_.toMap))
 
   private[this] def describeAclsWith[F[_]](
     withAdminClient: WithAdminClient[F],