《KAFKA官方文档》5.2 APIs

原文链接 译者:flystarfly

2. APIs

Kafka包含四种核心的API:

  1. Producer API支持应用将数据流发送到Kafka集群的主题。
  2. Consumer API支持应用从Kafka集群的主题中读取数据流。
  3. Streams API支持数据流从输入主题转化到输出主题。
  4. 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已被弃用,仅仅出于兼容的目的而存在。 有关他们的信息可以在
这里
找到。

原创文章,转载请注明: 转载自并发编程网 – ifeve.com本文链接地址: 《KAFKA官方文档》5.2 APIs

FavoriteLoading添加本文到我的收藏
  • Trackback 关闭
  • 评论 (0)
  1. 暂无评论

您必须 登陆 后才能发表评论

return top