Packages

kaffe

1.9.1
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
1 Dependency
5 Dependants
Files
Activity
kaffe lib kaffe config.ex
Raw

lib/kaffe/config.ex 

defmodule Kaffe.Config do

  def heroku_kafka_endpoints do

    "KAFKA_URL"

    |> System.get_env()

    |> heroku_kafka_endpoints

  end



  def heroku_kafka_endpoints(kafka_url) do

    kafka_url

    |> String.replace("kafka+ssl://", "")

    |> String.replace("kafka://", "")

    |> String.split(",")

    |> Enum.map(&url_endpoint_to_tuple/1)

  end



  def url_endpoint_to_tuple(endpoint) do

    [ip, port] = endpoint |> String.split(":")

    {ip |> String.to_atom(), port |> String.to_integer()}

  end



  def ssl_config do

    ssl_config(client_cert(), client_cert_key())

  end



  def ssl_config(_client_cert = nil, _client_cert_key = nil) do

    []

  end



  def ssl_config(client_cert, client_cert_key) do

    [

      ssl: [

        cert: client_cert,

        key: client_cert_key

      ]

    ]

  end



  def client_cert do

    case System.get_env("KAFKA_CLIENT_CERT") do

      nil -> nil

      cert -> extract_der(cert)

    end

  end



  def client_cert_key do

    case System.get_env("KAFKA_CLIENT_CERT_KEY") do

      nil -> nil

      cert_key -> extract_type_and_der(cert_key)

    end

  end



  def decode_pem(pem) do

    pem

    |> :public_key.pem_decode()

    |> List.first()

  end



  def extract_der(cert) do

    {_type, der, _} = decode_pem(cert)

    der

  end



  def extract_type_and_der(cert_key) do

    {type, der_cert, _} = decode_pem(cert_key)

    {type, der_cert}

  end

end