使用 Rest 代理连接到主题
Connecting to topics using Rest proxy
我是 Kafka 的新手。我已经像往常一样实现了我的消费者 Java springboot application.I 需要使用 Kafka rest 代理连接到远程代理上部署的主题。
我无法理解如果我使用 Kafka rest proxy.Where 我应该更改我的代码以包含其余部分 proxy.Do 我需要将我的代码结构完全不同,因为我没有在创建时考虑休息代理。
我可能用错了术语。
任何帮助或指导都会有很大帮助。
REST 代理可用于任何 HTTP 客户端,而不是 Kafka 消费者(因此创建 WebClient bean 而不是 ConsumerFactory 等)
您可以参考它的文档,了解如何通过 HTTP 使用记录,但简单地说,在您解析数据之前,代码将完全不同
我是 Kafka 的新手。我已经像往常一样实现了我的消费者 Java springboot application.I 需要使用 Kafka rest 代理连接到远程代理上部署的主题。 我无法理解如果我使用 Kafka rest proxy.Where 我应该更改我的代码以包含其余部分 proxy.Do 我需要将我的代码结构完全不同,因为我没有在创建时考虑休息代理。 我可能用错了术语。 任何帮助或指导都会有很大帮助。
REST 代理可用于任何 HTTP 客户端,而不是 Kafka 消费者(因此创建 WebClient bean 而不是 ConsumerFactory 等)
您可以参考它的文档,了解如何通过 HTTP 使用记录,但简单地说,在您解析数据之前,代码将完全不同