KafkaBatcher.Behaviours.Producer behaviour (kafka_batcher v1.1.1)

KafkaBatcher.Behaviours.Producer adds an abstraction level over producer implementations in various Kafka libs. Defines the callbacks that a Kafka producer should implement

Summary

Types

event()

events()

Callbacks

do_produce(events, topic, partition, config)

get_partitions_count(binary)

start_client()

start_producer(binary, t)

Types

event()

@type event() :: KafkaBatcher.MessageObject.t()

events()

@type events() :: [event()]

Callbacks

do_produce(events, topic, partition, config)

@callback do_produce(
  events :: events(),
  topic :: binary(),
  partition :: non_neg_integer() | nil,
  config :: Keyword.t()
) :: :ok | {:error, binary() | atom()}

get_partitions_count(binary)

@callback get_partitions_count(binary()) :: {:ok, integer()} | {:error, binary() | atom()}

start_client()

@callback start_client() :: {:ok, pid()} | {:error, any()}

start_producer(binary, t)

@callback start_producer(binary(), Keyword.t()) :: :ok | {:error, any()}