0

我有一个使用 confluent-kafka-go 绑定用 Go 编写的 kafka 生产者。

我希望我的 kafka 生产者与支持 HTTP CONNECT 隧道的 HTTP 代理后面的 kafka 代理建立连接。

librdkafka 支持这个吗?confluent-kafka-go 支持这个吗?如果是,请指向相关文档或提供说明如何完成的代码片段。

如果不支持,添加支持有多难?

4

1 回答 1

2

这些客户端仅使用 Kafka TCP 协议;他们不执行内容协商或使用 HTTP CONNECT 方法建立连接。

如果要使用 HTTP 协议,则需要使用 HTTP 客户端

于 2021-10-01T14:02:32.910 回答