ExKcl

WARNING: A work in progress

• Dynamodb Streams
• Kinesis Streams

Installation

def deps do
  [{:ex_kcl, github: "nerdyworm/ex_kcl"}]
end

Usage

defmodule Stream do
  use ExKcl.Stream, otp_app: :example
end

defmodule Consumer do
  use ExKcl.StreamConsumer

  def handle_events(events, _from, state) do
    IO.puts "consumer: #{length(events)}"
    {:noreply, [], state}
  end
end

config :example, Stream, [
  stream_name: "stream_name",
  adapter: ExKcl.Adapters.Kinesis,
  handlers: [Consumer]
]

TODO

• handle shard does not exist error gracefully
• handle provisioned throughput errors on leases