Packages

kafka_impl

0.5.0
0.5.0 0.4.5 0.4.4 0.4.3 0.4.2 0.3.3 0.3.2 0.3.1 0.3.0 0.2.0 0.1.0

A wrapper around KafkaEx so you can mock it in test.

HexDocs

Current section

Files

Jump to
Readme
11 Versions
1 Dependency
Dependants
Files
Activity
kafka_impl lib kafka_impl.ex
Raw

lib/kafka_impl.ex 

defmodule KafkaImpl do

  @kafka_impl Application.fetch_env!(:kafka_impl, :impl)



  @callback metadata(Keyword.t) :: KafkaEx.Protocol.Metadata.Response.t

  defdelegate metadata(opts \\ []), to: @kafka_impl



  @callback create_no_name_worker(KafkaEx.uri(), String.t) :: Supervisor.on_start_child

  defdelegate create_no_name_worker(brokers, consumer_group), to: @kafka_impl



  @callback create_no_name_worker(String.t | atom, KafkaEx.uri(), String.t) :: Supervisor.on_start_child

  defdelegate create_no_name_worker(server_module, brokers, consumer_group), to: @kafka_impl



  @callback latest_offset(binary, integer, atom|pid) :: [KafkaEx.Protocol.Offset.Response.t] | :topic_not_found

  defdelegate latest_offset(topic, partition, name \\ KafkaEx.Server), to: @kafka_impl



  @callback offset_commit(pid() | atom, KafkaEx.Protocol.OffsetCommit.Request.t) :: KafkaEx.Protocol.OffsetCommit.Response.t

  defdelegate offset_commit(worker_name, offset_commit_request), to: @kafka_impl



  @callback earliest_offset(binary, integer, atom|pid) :: [KafkaEx.Protocol.Offset.Response.t] | :topic_not_found

  defdelegate earliest_offset(topic, partition, name \\ KafkaEx.Server), to: @kafka_impl



  @callback fetch(binary, number, Keyword.t) :: [KafkaEx.Protocol.Fetch.Response.t] | :topic_not_found

  defdelegate fetch(topic, partition, opts \\ []), to: @kafka_impl



  @callback produce(KafkaEx.Protocol.Produce.Request.t, Keyword.t) :: nil | :ok | {:ok, integer} | {:error, :closed} | {:error, :inet.posix} | {:error, any} | iodata | :leader_not_available

  defdelegate produce(request, opts \\ []), to: @kafka_impl



  @spec offset(binary, number, :calendar.datetime|atom, atom|pid) :: [KafkaEx.Protocol.Offset.Response.t] | :topic_not_found

  defdelegate offset(topic, partition, time, name \\ KafkaEx.Server), to: @kafka_impl



  @callback offset_fetch(atom, KafkaEx.Protocol.OffsetFetch.Request.t) :: [KafkaEx.Protocol.OffsetFetch.Response.t] | :topic_not_found

  defdelegate offset_fetch(worker_name, offset_fetch_request), to: @kafka_impl

end