akka-kinesis supports Akka commponets for AWS Kinesis.
- KPLFlow
- KCLSource
- KCLSourceOnDynamoDBStreams (for DynamoDB Streams)
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
)