Packages

p

fs2.kafka

producer

package producer

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Type Members

  1. trait MkProducer[F[_]] extends AnyRef

    A capability trait representing the ability to instantiate the Java Producer that underlies the fs2-kafka KafkaProducer.

    A capability trait representing the ability to instantiate the Java Producer that underlies the fs2-kafka KafkaProducer. This is needed in order to instantiate fs2.kafka.KafkaProducer and fs2.kafka.TransactionalKafkaProducer.

    By default, the instance provided by MkProducer.mkProducerForSync will be used. However, this behaviour can be overridden, e.g. for testing purposes, by placing an alternative implicit instance in lexical scope.

Value Members

  1. object MkProducer

Ungrouped