KafkaBatcher.ConnectionManager (kafka_batcher v1.1.1)

Abstraction layer over Kafka library.

Manages a connection to Kafka, producers processes and does reconnect if something goes wrong.

Summary

Returns a specification to start this module under a supervisor

Checks that Kafka client is already started

start_link()

@spec child_spec(nil) :: map()

Returns a specification to start this module under a supervisor

@spec client_started?() :: boolean()

Checks that Kafka client is already started

@spec start_link() :: :ignore | {:error, any()} | {:ok, pid()}