KafkaEx.NetworkClient

Summary

close_socket(socket)
create_socket(host, port)
format_host(host)
send_async_request(broker, data)
send_sync_request(broker, data, timeout \\ 1000)

Functions

close_socket(socket)
create_socket(host, port)
format_host(host)
send_async_request(broker, data)
send_sync_request(broker, data, timeout \\ 1000)