Type Members

1.  trait KafkaAssignment[F[_]] extends AnyRef
2.  trait KafkaCommit[F[_]] extends AnyRef
3.  trait KafkaConsume[F[_], K, V] extends AnyRef
4.  trait KafkaConsumeChunk[F[_], K, V] extends KafkaConsume[F, K, V]
5.  trait KafkaConsumerLifecycle[F[_]] extends AnyRef
6.  trait KafkaMetrics[F[_]] extends AnyRef
7.  trait KafkaOffsets[F[_]] extends AnyRef
8.  trait KafkaOffsetsV2[F[_]] extends KafkaOffsets[F]
9.  trait KafkaSubscription[F[_]] extends AnyRef
10.  trait KafkaTopics[F[_]] extends AnyRef
11.  trait KafkaTopicsV2[F[_]] extends KafkaTopics[F]
12.  trait MkConsumer[F[_]] extends AnyRef

    A capability trait representing the ability to instantiate the Java Consumer that underlies the fs2-kafka KafkaConsumer.

    A capability trait representing the ability to instantiate the Java Consumer that underlies the fs2-kafka KafkaConsumer. This is needed in order to instantiate fs2.kafka.KafkaConsumer.
    
    

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