Class KinesisSink

A container for factory methods used to build Akka.NET Streams sinks to an Amazon Kinesis streams. Sinks can be used to send data to Kinesis streams with no acknowledgements - if you need confirmations, use KinesisFlow methods. Sinks carry about retries and rate limiting necessary to fit into AWS Kinesis constraints.

Inheritance

Object

KinesisSink

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 KinesisSink

Methods

| Improve this Doc View Source

ByPartitionAndBytes(String, KinesisFlowSettings, Func<IAmazonKinesis>)

Creates a sink that produces and inserts records to Amazon Kinsesis for a given (partition-key, message-payload) pair.

Declaration

public static Sink<(string, ByteString), NotUsed> ByPartitionAndBytes(string streamName, KinesisFlowSettings settings = null, Func<IAmazonKinesis> client = null)

Parameters

Type	Name	Description
String	streamName	Name of a stream. It must be present before using it.
KinesisFlowSettings	settings
Func<Amazon.Kinesis.IAmazonKinesis>	client	Amazon Kinesis client factory. After materialization, current Akka.NET Stream will take responsibility for managing that client, disposing it once stream will be stopped.

Returns

Type	Description
Akka.Streams.Dsl.Sink<System.ValueTuple<String, Akka.IO.ByteString>, Akka.NotUsed>

| Improve this Doc View Source

ByPartitionAndData(String, KinesisFlowSettings, Func<IAmazonKinesis>)

Creates a sink that produces and inserts records to Amazon Kinsesis for a given (partition-key, message-payload) pair.

Declaration

public static Sink<(string, MemoryStream), NotUsed> ByPartitionAndData(string streamName, KinesisFlowSettings settings = null, Func<IAmazonKinesis> client = null)

Parameters

Type	Name	Description
String	streamName	Name of a stream. It must be present before using it.
KinesisFlowSettings	settings
Func<Amazon.Kinesis.IAmazonKinesis>	client	Amazon Kinesis client factory. After materialization, current Akka.NET Stream will take responsibility for managing that client, disposing it once stream will be stopped.

Returns

Type	Description
Akka.Streams.Dsl.Sink<System.ValueTuple<String, MemoryStream>, Akka.NotUsed>

| Improve this Doc View Source

Create(String, KinesisFlowSettings, Func<IAmazonKinesis>)

Creates a default sink used to send raw records to Amazon Kinesis.

Declaration

public static Sink<PutRecordsRequestEntry, NotUsed> Create(string streamName, KinesisFlowSettings settings = null, Func<IAmazonKinesis> client = null)

Parameters

Type	Name	Description
String	streamName	Name of a stream. It must be present before using it.
KinesisFlowSettings	settings
Func<Amazon.Kinesis.IAmazonKinesis>	client	Amazon Kinesis client factory. After materialization, current Akka.NET Stream will take responsibility for managing that client, disposing it once stream will be stopped.

Returns

Type	Description
Akka.Streams.Dsl.Sink<Amazon.Kinesis.Model.PutRecordsRequestEntry, Akka.NotUsed>