Packages

object KinesisSchedulerSource

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

Value Members

  1. def apply(schedulerBuilder: (ShardRecordProcessorFactory) => Scheduler, settings: KinesisSchedulerSourceSettings): Source[CommittableRecord, Future[Scheduler]]

    Source that spawns a single Kinesis KCL Scheduler capable of consuming records from multiple Kinesis shards in coordination with other KCL Scheduler instances connected to the same stream.

    Source that spawns a single Kinesis KCL Scheduler capable of consuming records from multiple Kinesis shards in coordination with other KCL Scheduler instances connected to the same stream. Only a single KCL Scheduler instance can own the lease of a shard at any given time. The Kinesis service assigns each shard lease among the available instances.

    Every message emitted downstream belongs to a shard. Messages can be committed to save the progress of the client consuming that shard.

  2. def checkpointRecordsFlow(settings: KinesisSchedulerCheckpointSettings): Flow[CommittableRecord, KinesisClientRecord, NotUsed]
  3. def checkpointRecordsSink(settings: KinesisSchedulerCheckpointSettings): Sink[CommittableRecord, NotUsed]
  4. def sharded(schedulerBuilder: (ShardRecordProcessorFactory) => Scheduler, settings: KinesisSchedulerSourceSettings): SubFlow[CommittableRecord, Future[Scheduler], [+O]Source[O, Future[Scheduler]], RunnableGraph[Future[Scheduler]]]