0

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

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

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

4

1 回答 1

1

只要数据到达 Kafka,您使用什么协议跳来将数据到达那里并不重要。不过,我建议使用saramaorconfluent-kafka-go代替 HTTP

于 2021-09-29T12:37:14.727 回答