BrokerConnection

class kafka.BrokerConnection(host, port, afi, **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_per_connection.

check_version(timeout=2, strict=False)

Attempt to guess the broker version.

Note: This is a blocking call.

Returns: version tuple, i.e. (0, 10), (0, 9), (0, 8, 2), ...

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.errors.ConnectionError.

connect()

Attempt to connect and return ConnectionState

connected()

Return True iff socket is connected.

connecting()

Returns True if still connecting (this may encompass several different states, such as SSL handshake, authorization, etc).

disconnected()

Return True iff socket is closed

recv()

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