kayrock v0.1.15

Kayrock.BrokerConnection (kayrock v0.1.15) 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.

Link to this section Summary

Functions

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

Link to this section Functions

Link to this function

close(conn)

View Source
Link to this function

recv(conn, timeout \\ 3000)

View Source
Link to this function

send(conn, data)

View Source
Link to this function

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

View Source
Link to this function

stop(conn)

View Source