https://github.com/dpkp/kafka-python/blob/master/kafka/client_async.py#L597 
