Kafka充当回调URL

qni6mghb  于 2023-04-05  发布在  Apache
关注(0)|答案(1)|浏览(109)

Kafka在基础护理中的工作方式类似于发布和订阅(Pub/Sub)系统,我过去曾使用过Kafka,其中我有特定的Sping Boot 应用程序作为Producer,另一个Spark应用程序作为Consumer。
在Producer和Consumer两种情况下,代码都是以与Kafka交互的方式编写的,因为我们可以控制应用程序。
现在我想知道Kafka是否可以充当回调URL。
假设我们有一个外部API(公共API),因此,我们的想法是检查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.
yrwegjxp

yrwegjxp1#

Kafka不是HTTP服务。
您需要编写自己的HTTP服务器来 Package KafkaProducer,和/或使用Kafka REST Proxy等工具(但要确保执行回调的服务将以该API的预期格式发送事件)。

相关问题