View Source Kayrock.BrokerConnection (kayrock v0.2.0)

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)