akka-kinesis

CI Scala Steward badge Maven Central License

akka-kinesis supports Akka commponets for AWS Kinesis.

Support features

  • KPLFlow
  • KCLSource
  • KCLSourceOnDynamoDBStreams (for DynamoDB Streams)

Installation

Add the following to your sbt build (2.12.x, 2.13.x):

// if snapshot
resolvers += "Sonatype OSS Snapshot Repository" at "https://oss.sonatype.org/content/repositories/snapshots/"

val version = "..."

libraryDependencies += Seq(
  "com.github.j5ik2o" %% "akka-kinesis-kcl" % version, // for KCL
  "com.github.j5ik2o" %% "akka-kinesis-kpl" % version, // for KPL
  "com.github.j5ik2o" %% "akka-kinesis-kcl-dynamodb-streams" % version // for KCL with DynamoDB Streams
)