使用 Rest 代理连接到主题

问题描述

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

解决方法

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

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