Class KinesisSource

A container class for factory methods used to build Akka.NET Streams sources to an Amazon Kinesis streams. This provider is realized by periodically fetching the data, accordingly to settings specified inside ShardSettings configuration.

Inheritance

Object

KinesisSource

Inherited Members

Object.Equals(Object)

Object.Equals(Object, Object)

Object.GetHashCode()

Object.GetType()

Object.MemberwiseClone()

Object.ReferenceEquals(Object, Object)

Object.ToString()

Namespace: Akka.Streams.Kinesis

Assembly: Akka.Streams.Kinesis.dll

Syntax

public static class KinesisSource

Methods

Basic(ShardSettings, Func<IAmazonKinesis>)

Creates a basic source that will allow to connect to a single AWS Kinesis stream and shard. To combine sources targetting multiple shards, use Akka.Streams.Dsl.SourceOperations.Merge``3(Akka.Streams.Dsl.Source{``0,``2},Akka.Streams.IGraph{Akka.Streams.SourceShape{``1},``2},System.Boolean) method.

All requests will be send via provided Amazon Kinesis client. After materialization, current Akka.NET Stream will take full responsibility for managing that client, disposing it once stream will be stopped.

Declaration

public static Source<Record, NotUsed> Basic(ShardSettings settings, Func<IAmazonKinesis> client = null)

Parameters

Type	Name	Description
ShardSettings	settings
Func<Amazon.Kinesis.IAmazonKinesis>	client

Returns

Type	Description
Akka.Streams.Dsl.Source<Amazon.Kinesis.Model.Record, Akka.NotUsed>