//> using scala 2.13.12
//> using dep com.github.fd4s:fs2-kafka_2.13:1.11.0
import scala.concurrent.ExecutionContext
import cats.effect._
import fs2.kafka._
object TopicListener {
implicit val cs = IO.contextShift(ExecutionContext.global)
implicit val timer = IO.timer(ExecutionContext.global)
val x = KafkaConsumer.stream(null.asInstanceOf[ConsumerSettings[IO, String, String]])
.subscribeTo("asdasd")
.@@ // 1 <- no completions here
.records
.@@ // 2 <- everything is fine
}
Reproduction steps
Problem
An empty list of completions is returned.
Here is the original issue in metals: https://github.com/scalameta/metals/issues/5984