Packages

elsa

0.2.0
1.0.0-rc.3 1.0.0-rc.2 1.0.0-rc.1 0.12.3 0.12.2 0.12.1 0.12.0 0.11.1 0.11.0 0.10.1 0.10.0 0.9.0 0.8.1 0.8.0 0.7.1 0.7.0 0.6.0 0.5.0 0.4.1 0.4.0 0.3.0 0.2.0 0.1.0

Elsa is a full-featured Kafka library written in Elixir and extending the :brod library with additional support from the :kafka_protocol Erlang libraries to provide capabilities not available in :brod.

HexDocs

Current section

Files

Jump to
Readme
23 Versions
1 Dependency
Dependants
Files
Activity
elsa lib elsa.ex
Raw

lib/elsa.ex 

defmodule Elsa do

  @moduledoc """

  Documentation for Elsa.

  """



  import Record



  defrecord :kafka_message, extract(:kafka_message, from_lib: "kafka_protocol/include/kpro_public.hrl")



  defdelegate list_topics(endpoints), to: Elsa.Topic, as: :list



  defdelegate topic?(endpoints, topic), to: Elsa.Topic, as: :exists?



  defdelegate create_topic(endpoints, topic, opts \\ []), to: Elsa.Topic, as: :create



  defdelegate delete_topic(endpoints, topic), to: Elsa.Topic, as: :delete



  defdelegate produce_sync(endpoints, topic, partition, key, value), to: Elsa.Producer, as: :produce_sync



  def fetch() do

  end



  def default_client(), do: :elsa_default_client



  defmodule ConnectError do

    defexception [:message]

  end

end