有没有办法配置kafkaconsumer(apache.kafka.kafka客户机)通过代理与kafka代理一起工作?

9njqaruj  于 2021-06-04  发布在  Kafka
关注(0)|答案(1)|浏览(377)

我正在使用一个kafkaconsumerjava客户端来连接kafka代理。我的用户可以在kafkaconsumer和代理之间定义一个代理(ip:port)。

----------------------         -------------         -----------------------
| Application client |  <--->  | TCP Proxy |  <--->  | Target (e.g. kafka) |
----------------------         -------------         -----------------------

如果没有代理,配置“boostrap.servers”和代理列表就足以建立初始连接。
我的问题是,如何管理kafkaconsumer通过代理初始化与代理的连接?Apache·Kafka有这种支持吗?
我试着找一处房产,比如 listeners '和' advertised.listeners '但是,它们是代理配置,我无法配置代理。

vohkndzv

vohkndzv1#

tcp协议需要建立一个套接字握手,然后从上游kafka请求事件,然后作为流式响应转发回请求的客户端。。。。
如果构建tcp协议对您来说太多,那么您可以使用kafka rest代理。
或者,澄清为什么不能直接连接到任何代理

相关问题