From fe05a52322371343f896276810cdd922f2d0331b Mon Sep 17 00:00:00 2001 From: Ben Plommer Date: Tue, 15 Mar 2022 11:21:09 +0000 Subject: [PATCH] Update KafkaConsumer.scala --- modules/core/src/main/scala/fs2/kafka/KafkaConsumer.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/modules/core/src/main/scala/fs2/kafka/KafkaConsumer.scala b/modules/core/src/main/scala/fs2/kafka/KafkaConsumer.scala index 994f644b0..80c3a8f01 100644 --- 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,