Put missing apply method back

fd4s · Mar 20, 2022 · a7261d3 · a7261d3
1 parent 097ac04
commit a7261d3
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/modules/core/src/main/scala/fs2/kafka/ProducerSettings.scala b/modules/core/src/main/scala/fs2/kafka/ProducerSettings.scala
@@ -368,6 +368,12 @@ object ProducerSettings {
       valueSerializer = valueSerializer.forValue
     )
 
+  def apply[F[_], K, V](
+    implicit keySerializer: RecordSerializer[F, K],
+    valueSerializer: RecordSerializer[F, V]
+  ): ProducerSettings[F, K, V] =
+    create(keySerializer = keySerializer.forKey, valueSerializer = valueSerializer.forValue)
+
   /**
     * Create a `ProducerSettings` instance using placeholder serializers that serialize nothing.
     * These can be subsequently replaced using `withSerializers`, allowing configuration of