apache-kafka - 将数据从 Rest API 发送到 kafka
问题描述
我刚刚开始学习 Kafka,我正在尝试构建一个原型来拥有一个 REST API 的生产者并将数据发送给 Kafka 消费者。我浏览了很多文档来找出一些特定的程序。
我无法理解是否有一个连接器可以像为 Apache Kafka 提供的文件连接器或 JDBC 连接器一样使用。我应该为此编写自定义连接器吗?
我很困惑从哪里开始。我特别在寻找一些关于如何完成这项工作的结构化文档或想法。
解决方案
听起来您在谈论REST Proxy中已经存在的功能。这提供了一个 REST API,用于将数据生成到 Kafka,或从 Kafka 消费数据。
编辑:从您的评论中,我理解您的问题有所不同。如果要将数据从 REST 端点提取到 Kafka,可以使用 Kafka Connect 和kafka-connect-rest插件。这里有一个使用的例子。
推荐阅读
- python - 无法抓取视频(缩放流)
- java - con.rollback() 会回滚 con.commit() 已经提交的更改吗?
- css - 如何更改进度条末尾显示的百分比的文本颜色
- sql - 如何从总小时数的总和中获得百分比
- oracle-apex - Oracle Apex 阻止打开新选项卡和新窗口
- php - 使用php和sql从数据库中删除数据
- sql-server - 从本地 Azure 和备份数据库导出表
- javascript - 是否可以在 SSR Nuxt 应用程序中间件中调用本地存储?
- javascript - Magento 2.4.3 安装后未加载 css 和 js。在 url 'pub' 中丢失
- linux - 有条件地为特定列/单元格设置 bash 背景/前景色