kafka接口API

原创
半兽人 发表于: 2016-05-11   最后更新时间: 2020-11-15 22:40:32  
{{totalSubscript}} 订阅, 104,566 游览

Apache Kafka引入一个新的java客户端(在org.apache.kafka.clients 包中),替代老的Scala客户端,但是为了兼容,将会共存一段时间。为了减少依赖,这些客户端都有一个独立的jar,而旧的Scala客户端继续与服务端保留在同个包下。

Kafka有5个核心API:

  1. Producer API 允许应用程序发送数据流到kafka集群中的topic。
  2. Consumer API 允许应用程序从kafka集群的topic中读取数据流。
  3. Streams API 允许从输入topic转换数据流到输出topic。
  4. Connect API 通过实现连接器(connector),不断地从一些源系统或应用程序中拉取数据到kafka,或从kafka提交数据到宿系统(sink system)或应用程序。
  5. Admin API 用于管理和检查topic,broker和其他Kafka对象。

kafka公开了其所有的功能协议,与语言无关。只有java客户端作为kafka项目的一部分进行维护,其他的作为开源的项目提供,这里提供了非java客户端的列表。
https://cwiki.apache.org/confluence/display/KAFKA/Clients

更新于 2020-11-15
在线,15分钟前登录

☞静铃夜☜ 1年前

这个kafka教程,棒极了

你好,我想请教您一个问题,我现在配置kafka的用户SASL/PLAIN,自己在机器上测试是可以发送和接收消息的。但在php连接kafka的时候,不知道应该如何连接用户。

查看kafka更多相关的文章或提一个关于kafka的问题,也可以与我们一起分享文章