Merge pull request #511 from jopecko/jopecko/fix-deprecation-warning

correct deprecation message for adminClientStream
fd4s · Feb 9, 2021 · f56aecc · f56aecc
2 parents d285b1c + eb9b93e
commit f56aecc
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/modules/core/src/main/scala/fs2/kafka/package.scala b/modules/core/src/main/scala/fs2/kafka/package.scala
@@ -80,7 +80,7 @@ package object kafka {
   ): Resource[F, KafkaAdminClient[F]] =
     KafkaAdminClient.resource(settings)
 
-  @deprecated("use KafkaConsumer.stream", "1.2.0")
+  @deprecated("use KafkaAdminClient.stream", "1.2.0")
   def adminClientStream[F[_]](settings: AdminClientSettings[F])(
     implicit F: Concurrent[F],
     context: ContextShift[F]