object KafkaConsumer

Source
KafkaConsumer.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. KafkaConsumer
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Type Members

  1. implicit final class StreamOps[F[_], K, V] extends AnyRef

Value Members

  1. def apply[F[_]]: ConsumerPartiallyApplied[F]
  2. def resource[F[_], K, V](settings: ConsumerSettings[F, K, V])(implicit F: Async[F], mk: MkConsumer[F]): Resource[F, KafkaConsumer[F, K, V]]

    Creates a new KafkaConsumer in the Resource context, using the specified ConsumerSettings.

    Creates a new KafkaConsumer in the Resource context, using the specified ConsumerSettings. Note that there is another version where F[_] is specified explicitly and the key and value type can be inferred, which allows you to use the following syntax.

    KafkaConsumer.resource[F].using(settings)
  3. def stream[F[_], K, V](settings: ConsumerSettings[F, K, V])(implicit F: Async[F], mk: MkConsumer[F]): Stream[F, KafkaConsumer[F, K, V]]

    Creates a new KafkaConsumer in the Stream context, using the specified ConsumerSettings.

    Creates a new KafkaConsumer in the Stream context, using the specified ConsumerSettings. Note that there is another version where F[_] is specified explicitly and the key and value type can be inferred, which allows you to use the following syntax.

    KafkaConsumer.stream[F].using(settings)