object ProducerMessage
Classes that are used in both javadsl.Producer and scaladsl.Producer.
- Source
- ProducerMessage.scala
- Alphabetic
- By Inheritance
- ProducerMessage
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- sealed trait Envelope[K, V, +PassThrough] extends AnyRef
Type accepted by
Producer.committableSink
andProducer.flexiFlow
with implementationsType accepted by
Producer.committableSink
andProducer.flexiFlow
with implementations- Message publishes a single message to its topic, and continues in the stream as Result
- MultiMessage publishes all messages in its
records
field, and continues in the stream as MultiResult- PassThroughMessage does not publish anything, and continues in the stream as PassThroughResult
The
passThrough
field may hold any element that is passed through theProducer.flexiFlow
and included in the Results. That is useful when some context is needed to be passed on downstream operations. That could be done with unzip/zip, but this is more convenient. It can for example be a ConsumerMessage.CommittableOffset or ConsumerMessage.CommittableOffsetBatch that can be committed later in the flow. - final case class Message[K, V, +PassThrough](record: ProducerRecord[K, V], passThrough: PassThrough) extends Envelope[K, V, PassThrough] with Product with Serializable
Envelope implementation that produces a single message to a Kafka topic, flows emit a Result for every element processed.
Envelope implementation that produces a single message to a Kafka topic, flows emit a Result for every element processed.
The
record
contains a topic name to which the record is being sent, an optional partition number, and an optional key and value.The
passThrough
field may hold any element that is passed through theProducer.flow
and included in the Result. That is useful when some context is needed to be passed on downstream operations. That could be done with unzip/zip, but this is more convenient. It can for example be a ConsumerMessage.CommittableOffset or ConsumerMessage.CommittableOffsetBatch that can be committed later in the flow. - final case class MultiMessage[K, V, +PassThrough](records: Seq[ProducerRecord[K, V]], passThrough: PassThrough) extends Envelope[K, V, PassThrough] with Product with Serializable
Envelope implementation that produces multiple message to a Kafka topics, flows emit a MultiResult for every element processed.
Envelope implementation that produces multiple message to a Kafka topics, flows emit a MultiResult for every element processed.
Every element in
records
contains a topic name to which the record is being sent, an optional partition number, and an optional key and value.The
passThrough
field may hold any element that is passed through theProducer.flow
and included in the MultiResult. That is useful when some context is needed to be passed on downstream operations. That could be done with unzip/zip, but this is more convenient. It can for example be a ConsumerMessage.CommittableOffset or ConsumerMessage.CommittableOffsetBatch that can be committed later in the flow. - final case class MultiResult[K, V, PassThrough] extends Results[K, V, PassThrough] with Product with Serializable
Results implementation emitted when all messages in a MultiMessage have been successfully published.
- final case class MultiResultPart[K, V] extends Product with Serializable
- final case class PassThroughMessage[K, V, +PassThrough](passThrough: PassThrough) extends Envelope[K, V, PassThrough] with Product with Serializable
Envelope implementation that does not produce anything to Kafka, flows emit a PassThroughResult for every element processed.
Envelope implementation that does not produce anything to Kafka, flows emit a PassThroughResult for every element processed.
The
passThrough
field may hold any element that is passed through theProducer.flow
and included in the Results. That is useful when some context is needed to be passed on downstream operations. That could be done with unzip/zip, but this is more convenient. It can for example be a ConsumerMessage.CommittableOffset or ConsumerMessage.CommittableOffsetBatch that can be committed later in the flow. - final case class PassThroughResult[K, V, PassThrough] extends Results[K, V, PassThrough] with Product with Serializable
Results implementation emitted when a PassThroughMessage has passed through the flow.
- final case class Result[K, V, PassThrough] extends Results[K, V, PassThrough] with Product with Serializable
Results implementation emitted when a Message has been successfully published.
- sealed trait Results[K, V, PassThrough] extends AnyRef
Output type produced by
Producer.flexiFlow
andTransactional.flow
.
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
- 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
- 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
- def multi[K, V](records: Collection[ProducerRecord[K, V]]): Envelope[K, V, NotUsed]
Java API: Create a multi-message containing several
records
.Java API: Create a multi-message containing several
records
.- K
the type of keys
- V
the type of values
- def multi[K, V, PassThrough](records: Collection[ProducerRecord[K, V]], passThrough: PassThrough): Envelope[K, V, PassThrough]
Java API: Create a multi-message containing several
records
and onepassThrough
.Java API: Create a multi-message containing several
records
and onepassThrough
.- K
the type of keys
- V
the type of values
- PassThrough
the type of data passed through
- def multi[K, V](records: Seq[ProducerRecord[K, V]]): Envelope[K, V, NotUsed]
Create a multi-message containing several
records
.Create a multi-message containing several
records
.- K
the type of keys
- V
the type of values
- def multi[K, V, PassThrough](records: Seq[ProducerRecord[K, V]], passThrough: PassThrough): Envelope[K, V, PassThrough]
Create a multi-message containing several
records
and onepassThrough
.Create a multi-message containing several
records
and onepassThrough
.- K
the type of keys
- V
the type of values
- PassThrough
the type of data passed through
- 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 passThrough[K, V](): Envelope[K, V, NotUsed]
Create a pass-through message not containing any records for use with
withContext
flows and sinks.Create a pass-through message not containing any records for use with
withContext
flows and sinks. In some cases the type parameters need to be specified explicitly.- K
the type of keys
- V
the type of values
- def passThrough[K, V, PassThrough](passThrough: PassThrough): Envelope[K, V, PassThrough]
Create a pass-through message not containing any records.
Create a pass-through message not containing any records. In some cases the type parameters need to be specified explicitly.
- K
the type of keys
- V
the type of values
- PassThrough
the type of data passed through
- def single[K, V](record: ProducerRecord[K, V]): Envelope[K, V, NotUsed]
Create a message containing the
record
.Create a message containing the
record
.- K
the type of keys
- V
the type of values
- def single[K, V, PassThrough](record: ProducerRecord[K, V], passThrough: PassThrough): Envelope[K, V, PassThrough]
Create a message containing the
record
and apassThrough
.Create a message containing the
record
and apassThrough
.- K
the type of keys
- V
the type of values
- PassThrough
the type of data passed through
- 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()
- object MultiResult extends Serializable
- object MultiResultPart extends Serializable
- object PassThroughResult extends Serializable
- object Result extends Serializable