BrokerConnection

class kafka.BrokerConnection(host, port, **configs)

blacked_out()

Return true if we are disconnected from the given node and can’t re-establish a connection yet

can_send_more()

Return True unless there are max_in_flight_requests.

close(error=None)

Close socket and fail all in-flight-requests.

Parameters:error (Exception, optional) – pending in-flight-requests will be failed with this exception. Default: kafka.common.ConnectionError.

connect()

Attempt to connect and return ConnectionState

connected()

Return True iff socket is connected.

recv(timeout=0)

Non-blocking network receive.

Return response if available

send(request, expect_response=True)

send request, return Future()

Can block on network if request is larger than send_buffer_bytes