kafka.net.http_connect

class kafka.net.http_connect.HttpConnectProxy(proxy_url=None)[source]

Tunnels broker connections through an HTTP CONNECT proxy (RFC 7231 s4.3.6).

Registered for the http scheme – pass proxy_url='http://host:port' to KafkaConsumer/KafkaProducer/KafkaAdminClient.

Basic proxy auth is supported via URL credentials: http://user:pass@host:8080. Broker hostnames are always forwarded unresolved so the proxy handles DNS.

SCHEMES = ('http',)

connect_ex(sock, addr)[source]

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

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