页面树结构

版本比较

标识

  • 该行被添加。
  • 该行被删除。
  • 格式已经改变。

目录

面板
borderColor#00FFFF
borderStyledashed

原文链接 : http://kafka.apache.org/0101/documentation.html(修改该链接为官网对应的链接)

译文链接 : http://cwiki.apachecn.org/pages/viewpage.action?pageId=4882492(修改该链接为 ApacheCN 对应的译文链接)

贡献者 : @您的名字,ApacheCNApache中文网

kafka包括以下四个核心api

  1. Producer API 允许应用发送流数据给Kafka集群中的topic.
  2. Consumer API 允许应用读取流数据从Kafka集群中的topic.
  3. Streams API 允许转换流数据从输入topics到输出topics
  4. Connect API允许实现连接器持续的从一些源系统或者应用拉取数据到Kafka或者推送数据从Kafka到其他目的系统或者应用.
  5. AdminClient API 允许管理和检查topics,brokers和其他Kafka对象。

Kafka通过独立于语言的协议公开其所有功能,该协议具有许多编程语言的客户端.只有Java客户端作为主要的Kafka项目的一部门.其他客户端可以作为独立的开源项目使用.此处提供非Java客户端列表.

2.1 Producer API

生产者API允许应用发送流数据到Kafka集群上.
使用producer.可以使用以下的依赖:

代码块
themeEclipse
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-clients</artifactId>
<version>0.10.2.0</version>
</dependency>

2.2 Consumer API

消费者允许应用读取流数据从Kafka集群

使用消费者.你可以使用以下依赖:

代码块
themeEclipse
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-clients</artifactId>
<version>0.10.2.0</version>
</dependency>

2.3 Streams API

流API允许转换流数据从输入topic到输出topic
使用Streams APi 可以使用以下依赖:

代码块
themeEclipse
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-streams</artifactId>
<version>0.10.2.0</version>
</dependency>

2.4 Connect API

Connect API 允许实现connectors 持续的从某些源系统或者应用拉取数据或者从Kafka将数据推送到目的系统.

许多连接器的使用者不需要直接用Api,可以使用预先编译好的connectors而不需要写更多的代码.

2.5 AdminClient API

AdminClient API支持管理和检查topics,brokers,acls和Kafka对象。

使用AdminClient API,需要添加下面的maven依赖:

代码块
themeEclipse
<dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka-clients</artifactId>
    <version>0.11.0.0</version>
</dependency>

2.6 Legacy API

一个更有限的传统生产者和消费者api也包括在kafka。这些旧的Scala 老版本的生产者和消费者 api 也包括在 kafka。这些旧的 Scala API 已被弃用.仅用于兼容性目的。