有没有办法通过 golang 应用程序重定向 kafka 连接？

本篇文章向大家介绍《有没有办法通过 golang 应用程序重定向 kafka 连接？》，主要包括，具有一定的参考价值，需要的朋友可以参考一下。

我正在寻找一种使 golang 应用程序充当 kafka 代理/网关的方法。 我有一个 kafka 服务器在端口 localhost:1234 运行，还有一个 golang 应用程序在 localhost:5000 运行。每当任何客户端想要连接到 kafka 时，他应该首先连接到我的 golang 服务，我想在其中对用户执行一些验证（身份验证 + 权限等），然后将连接本身重定向到 kafka。

我不想实现一个将从连接读取并传递给 kafka 的中间接口，反之亦然。

我该怎么做？或者什么是这种方法的更好替代方案？

正确答案

这正是 kafka-proxy 项目已经做的事情。它是用 Go 编写的。

https://github.com/grepplabs/kafka-proxy

但总的来说，不，这不是一个好主意，因为 Kafka 应该配置为处理自己的身份验证，并且 Kafka 有一个往返网络协议；首先到达引导连接，然后从代理本身返回 advertized.listeners 。换句话说，您的经纪人需要返回代理地址并以某种方式告诉代理转发到特定的经纪人，而不仅仅是您的客户会知道它。

今天带大家了解了的相关知识，希望对你有所帮助；关于Golang的技术知识我们会一点点深入介绍，欢迎大家关注golang学习网公众号，一起学习编程~