Kafka 基础教程 — 核心API简介

转

2024-04-03

©版权

原文作者：吴声子夜歌原文地址： https://blog.csdn.net/cold___play/article/details/132122503

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>

阅读全文

文章标签： Kafka Kafka 教程