object Consumer
- Alphabetic
- By Inheritance
- Consumer
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- trait Control extends AnyRef
The materialized value of the consumer sources.
The materialized value of the consumer sources. Used for controlled shutdown.
Not for user extension
- Annotations
- @DoNotInherit()
- trait DrainingControl[T] extends Control
Combines control and stream completion materialized values, which allows the stream to be stopped in a controlled way without losing checkpoints.
Combines control and stream completion materialized values, which allows the stream to be stopped in a controlled way without losing checkpoints.
The stream completion materialized value will typically be that of a sink (e.g. 'Sink.ignore').
Not for user extension
- Annotations
- @DoNotInherit()
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
- 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 pairSource(settings: ConsumerSettings, sdkClientBuilder: EventProcessorClientBuilder, checkpointSettings: CheckpointSettings, checkpointStore: CheckpointStore): Source[(EventData, Checkpointable), Control]
- def source[T](settings: ConsumerSettings, sdkClientBuilder: EventProcessorClientBuilder, checkpointSettings: CheckpointSettings, checkpointStore: CheckpointStore)(unwrap: (EventData, Checkpointable) => T): Source[T, Control]
Source which applies a function to the
EventDataand checkpointable to build an arbitrary type.Source which applies a function to the
EventDataand checkpointable to build an arbitrary type. It is equivalent to 'sourceWithCheckpointableContext.asSource.map(pair => unwrap(pair._1, pair._2))' but without the overhead of the intermediate SourceWithContext. Supports "at-least-once delivery". - def sourceWithCheckpointableContext(settings: ConsumerSettings, sdkClientBuilder: EventProcessorClientBuilder, checkpointSettings: CheckpointSettings, checkpointStore: CheckpointStore): SourceWithContext[EventData, Checkpointable, Control]
Source which emits
EventDatatogether with the checkpointable as flow context, which allows checkpointing to the checkpoint store.Source which emits
EventDatatogether with the checkpointable as flow context, which allows checkpointing to the checkpoint store. Supports "at-least-once delivery": each event will likely be delivered once, but could be redelivered in failure cases. - 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 DrainingControl