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) |
close_socket(socket) |
create_socket(host, port) |
format_host(host) |
send_async_request(broker, data) |
send_sync_request(broker, data, timeout \\ 1000) |