diff --git a/zio-kafka/src/main/scala/zio/kafka/producer/Producer.scala b/zio-kafka/src/main/scala/zio/kafka/producer/Producer.scala index 1857a5c3a..744906581 100644 --- a/zio-kafka/src/main/scala/zio/kafka/producer/Producer.scala +++ b/zio-kafka/src/main/scala/zio/kafka/producer/Producer.scala @@ -41,7 +41,7 @@ trait Producer { def produceAll[R, K, V]( keySerializer: Serializer[R, K], valueSerializer: Serializer[R, V] - ): ZPipeline[R & Producer, Throwable, ProducerRecord[K, V], RecordMetadata] = + ): ZPipeline[R, Throwable, ProducerRecord[K, V], RecordMetadata] = ZPipeline.mapChunksZIO(records => produceChunk(records, keySerializer, valueSerializer)) /**