Webhook data to Kafka Connect



我使用Kafka连接从不同的地方提取数据:mysql、mongodb等。并发送到弹性搜索。

我想提取来源为webhook的数据。那么,我可以配置一些Kafka URL来向它发送posthttp请求吗?向我的Kafkahttp帖子请求发送什么是好的做法?

Confluent维护一个源可用的Kafka REST代理(请务必阅读项目的Confluent社区许可证(。这将允许您";发送POST请求";将这些数据转发给Kafka。除此之外,您可以自己编写一个简单的HTTP端点来执行同样的操作。

就我个人而言,我使用了Nifi的ListenHTTPhandler来接受webhook,然后解析、路由、过滤等到ProduceKafka请求中

否则";"拉取数据";不是一个网络挂钩;Kafka Connect http;Github上的源项目。

最新更新