Merge pull request #842 from scala-steward/update/series/3.x/kafka-cl…

…ients-3.1.0 Update kafka-clients to 3.1.0 in series/3.x
fd4s · Mar 9, 2022 · b5a938a · b5a938a
2 parents 0dd576b + d5a1b5f
commit b5a938a
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/build.sbt b/build.sbt
@@ -6,7 +6,7 @@ val confluentVersion = "7.0.1"
 
 val fs2Version = "3.2.5"
 
-val kafkaVersion = "3.0.0"
+val kafkaVersion = "3.1.0"
 
 val testcontainersScalaVersion = "0.40.0"
 

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],