kafka.net: Add HttpConnectProxy#2990
Conversation
0258773 to
3023bbf
Compare
3023bbf to
baa42aa
Compare
|
Thanks, the project is currently in an unreleased major transition from 2.x -> 3.x. You can leave the packaging issues unresolved for now (I will fix before publishing). I think if we're going to support more than one proxy I would like to use an abstract proxy interface and subclass it and avoid adding additional conditional checks. The pylint error seems unrelated to this PR. I'm not sure why it's popping up now. |
|
I'll land a quick refactor w/ abstract interface that you can leverage instead. |
Thank you! |
|
See #2992 |
baa42aa to
6380e1c
Compare
6380e1c to
3f7655f
Compare
Adds HttpConnectProxy, registered for the `http` scheme, which tunnels broker connections through an HTTP CONNECT proxy. Pass proxy_url='http://host:port' (or 'http://user:pass@host:port' for basic auth) to KafkaConsumer/KafkaProducer/KafkaAdminClient. Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
7aeb792 to
a58e173
Compare
Done refactoring the PR to match it. |
Changes:
kafka/net/http_connect.py: newHttpConnectProxyclasskafka/net/__init__.py: import and exportHttpConnectProxyalongsideSocks5ProxyTests:
pytest test/net/test_http_connect.py -vpytest test/net/ -qpylint --errors-only kafka/net/http_connect.pygit diff --check