kafka.net.inet

class kafka.net.inet.KafkaNetSocket(proxy_url=None)[source]

async connect(net, addrinfo, socket_options=(), timeout_at=None)[source]: Create non-blocking socket (with options) and connect to addrinfo tuple

connect_ex(sock, sockaddr)[source]

dns_lookup(host, port, raise_error=False)[source]

classmethod register_class(klass)[source]

async sock_connect(net, sock, sockaddr, timeout_at=None)[source]

socket(family=AddressFamily.AF_UNSPEC, sock_type=SocketKind.SOCK_STREAM, proto=6)[source]

async kafka.net.inet.create_connection(net, host, port, socket_options=(), proxy_url=None, timeout_at=None)[source]: Connect to host:port; raises KafkaConnectionError on failure