apache-kafka - 使用 Rest 代理连接到主题

Question

我是 Kafka 的新手。我已经将我的消费者实现为普通的 Java springboot 应用程序。我需要使用Kafka 休息代理连接到部署在远程代理上的主题。如果我使用 Kafka 休息代理，我无法理解它将如何发挥不同的作用。我应该在哪里更改我的代码以包含休息代理。我是否需要完全不同地构建我的代码，因为我没有考虑休息代理在创作时。我可能对术语有误。任何帮助或指导都会有很大帮助。

Answer 1

REST 代理将与任何 HTTP 客户端一起使用，而不是 Kafka 消费者（因此创建一个 WebClient bean 而不是 ConsumerFactory 等）

您可以参考其文档以了解如何通过 HTTP 使用记录，但简单地说，在您解析数据之前，代码将完全不同