misha_cafex v0.0.6 Cafex

Summary

Produce message to kafka server in the asynchronous way

Produce message to kafka server in the synchronous way

Start a consumer

Start a producer

See Cafex.Supervisor.stop_consumer/1

See Cafex.Supervisor.stop_producer/1

broker :: server

client_id :: String.t

server :: {host :: String.t, port :: 0..65535}

async_produce(producer, value, opts \\ [])

Produce message to kafka server in the asynchronous way.

fetch(topic_pid, partition, offset)

produce(producer, value, opts \\ [])

Produce message to kafka server in the synchronous way.

start_consumer(name, opts \\ [])

start_consumer(name :: atom, Cafex.Consumer.Manager.options) :: Supervisor.on_start_child

Start a consumer.

start_producer(topic_name, opts \\ [])

start_producer(topic_name :: String.t, opts :: Cafex.Producer.options) :: Supervisor.on_start_child

Start a producer.

Read Cafex.Producer for more details.

start_topic(name, brokers, opts \\ [])

stop_consumer(name)

See Cafex.Supervisor.stop_consumer/1.

stop_producer(sup)

See Cafex.Supervisor.stop_producer/1.