misha_cafex v0.0.5 Cafex.Producer.Worker

Summary

Functions

async_produce(pid, message)

produce(pid, message)

start_link(broker, topic, partition, opts \\ [])

stop(pid)

Functions

async_produce(pid, message)

produce(pid, message)

start_link(broker, topic, partition, opts \\ [])

stop(pid)