object KafkaProducer
- Source
- KafkaProducer.scala
- Alphabetic
- By Inheritance
- KafkaProducer
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- abstract class Metrics[F[_], K, V] extends KafkaProducer[F, K, V]
KafkaProducer.Metrics extends KafkaProducer to provide access to the underlying producer metrics.
- abstract class PartitionsFor[F[_], K, V] extends Metrics[F, K, V]
KafkaProducer.PartitionsFor extends KafkaProducer.Metrics to provide access to the underlying producer partitions.
- implicit final class ProducerOps[F[_], K, V] extends AnyVal
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- def apply[F[_]]: ProducerPartiallyApplied[F]
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- def pipe[F[_], K, V](producer: KafkaProducer[F, K, V])(implicit arg0: Concurrent[F]): Pipe[F, ProducerRecords[K, V], ProducerResult[K, V]]
Produces records in batches using the provided KafkaProducer.
- def pipe[F[_], K, V](settings: ProducerSettings[F, K, V])(implicit F: Async[F], mk: MkProducer[F]): Pipe[F, ProducerRecords[K, V], ProducerResult[K, V]]
Creates a KafkaProducer using the provided settings and produces record in batches.
- def resource[F[_], K, V](settings: ProducerSettings[F, K, V])(implicit F: Async[F], mk: MkProducer[F]): Resource[F, PartitionsFor[F, K, V]]
Creates a new KafkaProducer in the
Resource
context, using the specified ProducerSettings.Creates a new KafkaProducer in the
Resource
context, using the specified ProducerSettings. Note that there is another version whereF[_]
is specified explicitly and the key and value type can be inferred, which allows you to use the following syntax.KafkaProducer.resource[F].using(settings)
- def stream[F[_], K, V](settings: ProducerSettings[F, K, V])(implicit F: Async[F], mk: MkProducer[F]): Stream[F, PartitionsFor[F, K, V]]
Creates a new KafkaProducer in the
Stream
context, using the specified ProducerSettings.Creates a new KafkaProducer in the
Stream
context, using the specified ProducerSettings. Note that there is another version whereF[_]
is specified explicitly and the key and value type can be inferred, which allows you to use the following syntax.KafkaProducer.stream[F].using(settings)
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()