Packages

sealed trait Envelope[K, V, +PassThrough] extends AnyRef

Type accepted by Producer.committableSink and Producer.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 the Producer.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.

Source
ProducerMessage.scala
Linear Supertypes
AnyRef, Any
Known Subclasses
Message, MultiMessage, PassThroughMessage
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Envelope
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Abstract Value Members

  1. abstract def passThrough: PassThrough
  2. abstract def withPassThrough[PassThrough2](value: PassThrough2): Envelope[K, V, PassThrough2]