Returns a specification to start this module under a supervisor.

See Supervisor.

@spec flush(pid()) :: {atom(), pid()}

Flushes all the queued records in the producer batches.

@spec send(pid(), bitstring()) :: {atom(), pid()}

@spec send(pid(), list()) :: list()

Sends a list of string values or tuple key values to this producer's topic. flush/1 should be called to flush the records in the producer batches.

@spec send(pid(), bitstring(), bitstring()) :: {atom(), pid()}

Sends a key value record to this producer's topic. flush/1 should be be called to flush the records in the producer batches.

@spec start_link(%{topic: bitstring()}, list(), any()) :: GenServer.on_start()

Starts a Fluvio TopicProducer GenServer process linked to the current process.

Config example: %{topic: "some_topic", options: %{}}