Kayrock.BrokerConnection (kayrock v1.0.1)

Copy Markdown View Source

A connection to a kafka broker.

Implements the Connection behavior.

You shouldn't generally need to use this module directly. Use Kayrock or Kayrock.Client.

Summary

Functions

close(conn)
recv(conn, timeout \\ 5000)
send(conn, data)
start_link(host, port, opts, timeout \\ 5000)
stop(conn)

Functions

close(conn)

recv(conn, timeout \\ 5000)

send(conn, data)

start_link(host, port, opts, timeout \\ 5000)

stop(conn)