Execute KafkaProducer#send calls directly and not on the blocking thr…

…ead pool See #531
zio · Nov 22, 2022 · eab06b9 · eab06b9
1 parent b307c6f
commit eab06b9
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/zio-kafka/src/main/scala/zio/kafka/producer/Producer.scala b/zio-kafka/src/main/scala/zio/kafka/producer/Producer.scala
@@ -137,7 +137,7 @@ object Producer {
         done             <- Promise.make[Throwable, RecordMetadata]
         serializedRecord <- serialize(record, keySerializer, valueSerializer)
         runtime          <- ZIO.runtime[Any]
-        _ <- ZIO.attemptBlocking {
+        _ <- ZIO.attempt {
                p.send(
                  serializedRecord,
                  new Callback {
@@ -163,7 +163,7 @@ object Producer {
           done              <- Promise.make[Throwable, Chunk[RecordMetadata]]
           runtime           <- ZIO.runtime[Any]
           serializedRecords <- ZIO.foreach(records.toSeq)(serialize(_, keySerializer, valueSerializer))
-          _ <- ZIO.attemptBlocking {
+          _ <- ZIO.attempt {
                  val it: Iterator[(ByteRecord, Int)] =
                    serializedRecords.iterator.zipWithIndex
                  val res: Array[RecordMetadata] = new Array[RecordMetadata](records.length)