Close blocking

zio · Jan 11, 2023 · 7507378 · 7507378
1 parent 9aec63c
commit 7507378
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/zio-kafka/src/main/scala/zio/kafka/producer/Producer.scala b/zio-kafka/src/main/scala/zio/kafka/producer/Producer.scala
@@ -239,7 +239,7 @@ object Producer {
         value <- valueSerializer.serialize(r.topic, r.headers, r.value())
       } yield new ProducerRecord(r.topic, r.partition(), r.timestamp(), key, value, r.headers)
 
-    private[producer] def close: UIO[Unit] = ZIO.attempt(p.close(producerSettings.closeTimeout)).orDie
+    private[producer] def close: UIO[Unit] = ZIO.attemptBlocking(p.close(producerSettings.closeTimeout)).orDie
   }
 
   val live: RLayer[ProducerSettings, Producer] =