Getting Started

This module intends to be an enriched wrapper for the KPL, offered by AWS.

Installation

libraryDependencies += "io.github.etspaceman" %% "kinesis4cats-kpl" % "0.0.32"

Usage

import java.nio.ByteBuffer

import cats.effect._
import com.amazonaws.services.kinesis.producer._

import kinesis4cats.kpl.KPLProducer

object MyApp extends IOApp {
    override def run(args: List[String]) = {
        KPLProducer.Builder.default[IO].build.use(kpl => 
            for {
                _ <- kpl.put(
                    new UserRecord(
                        "my-stream", 
                        "my-partition-key", 
                        ByteBuffer.wrap("some-data".getBytes())
                    )
                )
                _ <- kpl.put(
                    new UserRecord(
                        "my-stream", 
                        "my-partition-key2", 
                        ByteBuffer.wrap("some-data2".getBytes())
                    )
                )
            } yield ExitCode.Success
        )
    }
}