Http4s

Provides a coupling of a KCLConsumer with an Http4s server, that services two routes:

• healthcheck (determines whether the http server is up)
• initialized (determines whether the KCL is up)

Installation

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

Usage

import cats.effect._
import cats.syntax.all._
import com.comcast.ip4s._
import software.amazon.kinesis.processor.SingleStreamTracker

import kinesis4cats.kcl._
import kinesis4cats.kcl.http4s.KCLService
import kinesis4cats.syntax.bytebuffer._

object MyApp extends ResourceApp.Forever {
    override def run(args: List[String]) = for {
        consumer <- KCLConsumer.Builder.default[IO](
                new SingleStreamTracker("my-stream"),
                "my-app-name",
            ).withCallback(
                (records: List[CommittableRecord[IO]]) =>
                    records.traverse_(r => IO.println(r.data.asString))
            ).build
        _ <- KCLService.server[IO](consumer, port"8080", host"0.0.0.0")
    } yield ()
}