BrokerConnection(host, port, afi, **configs)¶
Return true if we are disconnected from the given node and can’t re-establish a connection yet
Return True unless there are max_in_flight_requests.
Attempt to guess the broker version. This is a blocking call.
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.
Attempt to connect and return ConnectionState
Return True iff socket is connected.
Returns True if still connecting (this may encompass several different states, such as SSL handshake, authorization, etc).
Return True iff socket is closed
Non-blocking network receive.
Return response if available
send request, return Future()
Can block on network if request is larger than send_buffer_bytes