Kafka——核心API简介

偏执的太偏执、 2023-10-14 14:12 15阅读 0赞

### 1、 简介 ###

Kafka包括五个核心apis：

*  Producer API ：Producer API 用于将流数据发送至一个或多个Kafka主题中。
 *  Consumer API ：Consumer API 用于应用程序在订阅一个或多个主题后，对他们所产生的数据流进行处理。
 *  Streams API ：Streams API 使用来自一个或多个主题的输入流，并生成到一个或多个输出主题的输出流，提供一种有效的数据流处理方式。
 *  Connector API ：Connector API允许构建和运行可重用的生产者或消费者，将Kafka主题连接到现有的应用程序或数据系统。例如， 创建一个到关系型数据库连接器, 用于捕获对某张表的所有数据变更.
 *  AdminClient：允许管理和检查主题、代理和其他Kafka对象.

Kafka通过一个独立于语言的协议公开了它的所有功能，该协议的客户端可以在许多编程语言中使用。然而，只有Java客户端作为Kafka主要项目的一部分进行维护，其他客户机作为独立的开源项目提供。

### 2、Producer API （生产者API） ###

<dependency>
        <groupId>org.apache.kafka</groupId>
        <artifactId>kafka-clients</artifactId>
        <version>2.3.0</version>
    </dependency>

### 3、Consumer API（消费者API） ###

<dependency>
        <groupId>org.apache.kafka</groupId>
        <artifactId>kafka-clients</artifactId>
        <version>2.3.0</version>
    </dependency>

### 4、Streams API ###

<dependency>
        <groupId>org.apache.kafka</groupId>
        <artifactId>kafka-streams</artifactId>
        <version>2.3.0</version>
    </dependency>

### 5、AdminClient ###

<dependency>
        <groupId>org.apache.kafka</groupId>
        <artifactId>kafka-clients</artifactId>
        <version>2.3.0</version>
    </dependency>

发表评论取消回复

表情：

评论列表（有 0 条评论，15人围观）

还没有评论，来说两句吧...

相关阅读

相关【大数据入门核心技术-Kafka】（一）Kafka简介

【大数据入门核心技术-Kafka】（一）Kafka简介【大数据入门核心技术-Kafka】（一）Kafka简介【大数据入门核心技术-Kafka】（一）Kafka简介【

「爱情、让人受尽委屈。」/ 2024年03月31日 17:02/ 0 赞/ 118 阅读

相关 Kafka——核心API简介

1、简介 Kafka包括五个核心apis： Producer API ：Producer API 用于将流数据发送至一个或多个Kafka主题中。 Cons

偏执的太偏执、/ 2023年10月14日 14:12/ 0 赞/ 16 阅读

相关 Kafka：Kafka核心概念

1 消息系统简介 1.1 为什么要用消息系统？解耦各位系统之间通过消息系统这个统一的接口交换数据，无须了解彼此的存在；冗余部分消息系统具有消息持久化能

女爷i/ 2023年06月27日 08:37/ 0 赞/ 42 阅读

相关【Kafka】核心API

文章目录资料导学思维导图问卷前置基础适合人群开发环境准备虚拟机网络

矫情吗；*/ 2022年12月15日 03:24/ 0 赞/ 331 阅读

相关 kafka简介

消息队列为什么要使用消息队列 1. 解耦（类似Spring的IOC）允许你独立的扩展或修改两边的处理过程，只要确保它们遵守同样的接口约束。 2.

野性酷女/ 2022年10月23日 12:45/ 0 赞/ 284 阅读

相关 kafka简介

kafka简介本文翻译参考原文为：http://kafka.apache.org/intro 简介 kafka 是一个分布式流平台。那到底意味着什么？

女爷i/ 2022年09月28日 05:48/ 0 赞/ 246 阅读

相关 Kafka简介

Publish/Subscribe（Topic）简称发布/订阅模式。例如我微博有30万粉丝，我今天更新了一条微博，那么这30万粉丝都可以接收到我的微博更新，大家都可以消

￡神魔★判官ぃ/ 2022年09月08日 03:57/ 0 赞/ 254 阅读

相关 Kafka简介

概述 Kafka是Apache软件基金会旗下的子项目，是一个分布式的消息系统，它用简洁的设计实现了一个消息系统的功能。首先，回顾一下消息系统的基本语义： \-

青旅半醒/ 2022年05月31日 02:52/ 0 赞/ 298 阅读

相关 Kafka简介

背景：当今社会各种应用系统诸如商业、社交、搜索、浏览等像信息工厂一样不断的生产出各种信息，在大数据时代，我们面临如下几个挑战：如何收集这些巨大的信息

红太狼/ 2022年03月28日 12:56/ 0 赞/ 339 阅读

相关 09.Quartz 核心API简介

笔者认为, 若想灵活操作Quartz, 那么需要对Quartz的核心类和接口有一定的了解. quartz 最核心的类时Scheduler, 用于对定时任务的管理. 1. Q

ゝ一纸荒年。/ 2022年02月20日 04:37/ 0 赞/ 351 阅读