Fs2KafkaModule
object Fs2KafkaModule
Value members
Concrete methods
def makeConsumer[F[_], K, V](config: ConsumerConfig, blocker: Option[Blocker], createConsumer: Option[Map[String, String] => F[KafkaByteConsumer]])(using evidence$1: ConcurrentEffect[F], evidence$2: ContextShift[F], evidence$3: Timer[F], evidence$4: Deserializer[F, K], evidence$5: Deserializer[F, V]): Resource[F, KafkaConsumer[F, K, V]]
def makeConsumer[F[_], K, V](settings: ConsumerSettings[F, K, V])(using evidence$6: ConcurrentEffect[F], evidence$7: ContextShift[F], evidence$8: Timer[F]): Resource[F, KafkaConsumer[F, K, V]]
def makeProducer[F[_], K, V](config: ProducerConfig, blocker: Option[Blocker], createProducer: Option[Map[String, String] => F[KafkaByteProducer]])(using evidence$9: ConcurrentEffect[F], evidence$10: ContextShift[F], evidence$11: Serializer[F, K], evidence$12: Serializer[F, V]): Resource[F, KafkaProducer[F, K, V]]
def makeProducer[F[_], K, V](settings: ProducerSettings[F, K, V])(using evidence$13: ConcurrentEffect[F], evidence$14: ContextShift[F]): Resource[F, KafkaProducer[F, K, V]]