我正在使用一个kafkaconsumerjava客户端来连接kafka代理。我的用户可以在kafkaconsumer和代理之间定义一个代理(ip:port)。
---------------------- ------------- -----------------------
| Application client | <---> | TCP Proxy | <---> | Target (e.g. kafka) |
---------------------- ------------- -----------------------
如果没有代理,配置“boostrap.servers”和代理列表就足以建立初始连接。
我的问题是,如何管理kafkaconsumer通过代理初始化与代理的连接?Apache·Kafka有这种支持吗?
我试着找一处房产,比如 listeners
'和' advertised.listeners
'但是,它们是代理配置,我无法配置代理。
1条答案
按热度按时间vohkndzv1#
tcp协议需要建立一个套接字握手,然后从上游kafka请求事件,然后作为流式响应转发回请求的客户端。。。。
如果构建tcp协议对您来说太多,那么您可以使用kafka rest代理。
或者,澄清为什么不能直接连接到任何代理