Kafka
中的
API
详细介绍
Kafka 包含五个核心 api：
1. Producer API 允许应用程序向 Kafka 集群中的主题发送数据流。
2. Consumer API 允许应用程序从 Kafka 集群中的主题读取数据流。
3. Streams API 允许将数据流从输入主题转换为输出主题。
4. Connect API 允许实现从某些源系统或应用程序持续拉入 Kafka 或从 Kafka 推入某些接收系统或应
用的连接器。
5. AdminClient API 允许管理和检查主题、代理和其他 Kafka 对象。
Kafka 通过一个独立于语言的协议公开了它的所有功能，该协议有许多编程语言的客户端。然而，只
有 Java 客户端作为 Kafka 主项目的一部分进行维护，其他客户端则作为独立的开源项目提供。非 Java
客户端列表可在此处找到。
1 Producer API
Producer API 允许应用程序向 Kafka 集群中的主题发送数据流。
javadocs 中给出了如何使用生产者的示例。
要使用 Producer API，您可以使用以下 maven 依赖项：
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-clients</artifactId>
<version>1.1.0</version>
</dependency>
2 Consumer API
Consumer API 允许应用程序从 Kafka 集群中的主题读取数据流。
javadocs 中给出了如何使用消费者的示例。
要使用消费者，您可以使用以下 maven 依赖关系：
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-clients</artifactId>
资源评论
icysmile131
- 粉丝: 4602
- 资源: 536
最新资源
- 3D分割-基于Pytorch+3DUnet实现的3D体积语义分割算法-优质项目实战
- 3D分割-基于3D-UNet-Tensorflow实现的人类大脑图像分割算法-附详细流程教程+项目源码-优质项目分享
- 3D点云分割-通过使用注意力机制提高3D点云语义分割算法的性能-附项目源码-优质项目实战
- 3D-使用Kinect+PCL点云库测方体体积Demo-优质项目实战.zip
- 2024中国行政区划多边形矢量数据（含有十段线）
- 106从中序与后序遍历序列构造二叉树.zip
- java-leetcode题解之Making A Large Island.java
- java-leetcode题解之Make Array Strictly Increasing.java
- java-leetcode题解之Magical String.java
- java-leetcode题解之Lowest Common Ancestor of a Binary Tree.java
资源上传下载、课程学习等过程中有任何疑问或建议，欢迎提出宝贵意见哦~我们会及时处理！
点击此处反馈
