Packages

kaffe

1.22.0
2.1.0 2.0.0 1.28.0 1.27.2 1.27.1 1.27.0 1.26.0 1.25.0 1.24.0 1.23.0 1.22.0 1.21.0 1.20.0 1.19.0 1.18.0 1.17.0 1.15.0 1.14.1 1.13.0 1.12.0 1.11.0 1.10.0 1.9.2 1.9.1 1.9.0 1.8.0 1.7.0 1.6.0 1.5.0 1.4.3 1.4.0 1.3.1 1.3.0 1.2.1 1.2.0 1.1.0 1.0.0 0.5.0

An opinionated Elixir wrapper around brod, the Erlang Kafka client, that supports encrypted connections to Heroku Kafka out of the box.

HexDocs

Current section

Files

Jump to
Readme
38 Versions
2 Dependencies
5 Dependants
Files
Activity
kaffe lib kaffe.ex
Raw

lib/kaffe.ex 

defmodule Kaffe do

  @moduledoc """

  An opinionated, highly specific, Elixir wrapper around brod: the Erlang Kafka client. :coffee:



  **NOTE**: Although we're using this in production at Spreedly it is still under active development. The API may change and there may be serious bugs we've yet to encounter.

  """



  use Application



  require Logger



  def start(_type, _args) do

    import Supervisor.Spec, warn: false



    Logger.debug("event#start=#{__MODULE__}")



    if Application.get_env(:kaffe, :producer) do

      Logger.debug("event#start_producer_client=#{__MODULE__}")

      Kaffe.Producer.start_producer_client()

    end



    children = []



    opts = [strategy: :one_for_one, name: Kaffe.Supervisor]

    Supervisor.start_link(children, opts)

  end

end