使用 Kafka 和 Kafka REST 代理服务器

Question

我有一个应用程序的两端：

1. Python Flask 后端，使用 Kafka 以正常方式进行通信。
2. 用 Go 编写的机器代理，安装在客户端环境中，仅通过 Kafka REST 代理与 Kafka 通信。

现在的问题是这两端可以通信吗？例如，我的机器代理可以通过 REST 代理使用来自 Kafka 的消息，并以正常方式从另一端产生消息吗？还是两端都需要使用Kafka REST Proxy？

Answer 1

只要数据到达 Kafka，您使用什么协议跳来将数据到达那里并不重要。不过，我建议使用 sarama 或 confluent-kafka-go 而不是 HTTP