Kafka 作为回调 URL

Question

Kafka 在基础上像发布和订阅（Pub/Sub）系统一样工作，我过去曾与 Kafka 合作过，我有特定的 Spring Boot 应用程序作为生产者和另一个 Spark 应用程序作为消费者。

在生产者和消费者的情况下，代码都是以与 Kafka 交互的方式编写的，因为我们可以控制应用程序。

现在我想了解 Kafka 是否可以充当回调 URL。

所以场景是我们有一个外部 API（公共 API），它请求一个回调 URL。因此，我们的想法是检查 Kafka 充当回调 URL 的可行性，而不是拥有专门构建的新服务只是为了侦听外部 API。因此，我可以指定一个特定的主题作为回调 URL，其中捕获客户端请求发送的所有请求，并将使用另一个应用程序进一步使用主题并处理消息。

客户端对回调 URL 的要求

Callback URL
The partner URL is called by our system to send notifications through HTTP POST requests. Make sure that your server can handle a HTTP HEAD request called to verify the validity of your URL.

NOTE
Your URL must:

start with https
be a valid URL, provided as a URL-encoded string. Please see w3schools URL encoding reference to learn more about URL encoding.
not be greater than 255 characters.
not contain an IP or 'localhost'. Only ports 80 and 443 are permitted.

Answer 1

不，Kafka 不是 HTTP 服务。

您需要编写自己的 HTTP 服务器来包装 KafkaProducer，和/或使用像 Kafka REST Proxy 这样的工具（但要确保执行回调的服务将以该 API 的预期格式发送事件）。