《KAFKA官方文档》5.2 APIs
2023-03-14 22:31:08 时间
2. APIs
Kafka包含四种核心的API:
- Producer API支持应用将数据流发送到Kafka集群的主题。
- Consumer API支持应用从Kafka集群的主题中读取数据流。
- Streams API支持数据流从输入主题转化到输出主题。
- Connect API支持实现持续地从一些源系统或应用划入Kafka或者从Kafka推入一些源系统或应用的接口。
Kafka通过独立于语言的协议公开其所有功能,该协议具有可用于诸多编程语言的客户端。但是,只有Java客户端作为主Kafka项目的一部分进行维护,其他客户端只是独立的开源项目。可用的非Java客户端的列表请 点击这里。
2.1 Producer API
Producer API支持应用将数据流发送到Kafka集群的主题。
这里提供了如何使用Producer API的文档。
要使用Kafka Producer API,可以使用以下maven依赖:
<dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>0.10.2.0</version> </dependency>
2.2 Consumer API
Consumer API 支持应用从Kafka集群的主题中读取数据流。
这里提供了如何使用Consumer API的文档。
要使用Kafka Consumer API,可以使用以下maven依赖:
<dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>0.10.2.0</version> </dependency>
2.3 Streams API
Streams API 支持数据流从输入主题转化到输出主题。
这里提供了如何使用Streams API的文档。
有关使用Streams API的其他可用文档 请点击这里.
要使用Kafka Streams API,可以使用以下maven依赖:
<dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-streams</artifactId> <version>0.10.2.0</version> </dependency>
2.4 Connect API
Connect API 支持实现持续地将数据从一些源系统或应用划入Kafka或者从Kafka推入一些源系统或应用的接口。
Connect的大多数使用者不需要马上使用此API,但是它们可以使用预先建立的连接器,而无需编写任何代码。 有关使用Connect的其他可用文档 请点击这里.
那些想要实现定制连接器的人可以参考 这里的文档.
2.5 Legacy APIs
Kafka同样也包含了一些有限并且古老的producer以及consumer api。这些旧的Scala API已被弃用,仅仅出于兼容的目的而存在。 有关他们的信息可以在
这里找到。
相关文章
- 数据孤岛是业务效率的无声杀手
- 2023展望:新的一年将给大数据分析领域带来什么?
- 阿里云ADB基于Hudi构建Lakehouse的实践
- 大数据在医疗保健领域的使用案例
- 微软增加说明:KB5021751 更新扫描已经 / 即将过时 Office 过程中不会触碰用户隐私
- 2022 Gartner全球云数据库管理系统魔力象限发布 腾讯云数据库入选
- 场景化、重实操,分享一个实时数仓实践案例
- Arctic的湖仓一体践行之路
- 分布式计算MapReduce究竟是怎么一回事?
- 淘系数据模型治理优秀实践
- 大数据分析对医疗保健的影响
- 当我们说大数据Hadoop,究竟在说什么?
- 2022年及以后大数据的五个发展趋势
- 网易严选离线数仓治理实践
- 2023 年数据治理趋势
- 一份“靠谱”的年度经营计划,你学会了吗?
- 漫谈对大数据的思考
- 测试一下,读懂数据的能力,你有吗?
- 用艺术的眼光探索数据之美
- 聊聊数据分析成果如何落地