Update KafkaConsumer.scala

fd4s · Mar 15, 2022 · fe05a52 · fe05a52
1 parent 798d256
commit fe05a52
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/modules/core/src/main/scala/fs2/kafka/KafkaConsumer.scala b/modules/core/src/main/scala/fs2/kafka/KafkaConsumer.scala
@@ -116,7 +116,7 @@ object KafkaConsumer {
 
   private def createKafkaConsumer[F[_], K, V](
     settings: ConsumerSettings[F, K, V],
-    actor: KafkaConsumerActor[F, K, V],
+    actor: KafkaConsumerActor[F],
     fiber: FakeFiber[F],
     streamIdRef: Ref[F, StreamId],
     id: Int,