【Kafka】 Streams API

Metadata

title: 【Kafka】 Streams API
date: 2023-02-14 13:21
tags:
  - 行动阶段/完成
  - 主题场景/组件
  - 笔记空间/KnowladgeSpace/ProgramSpace/ModuleSpace
  - 细化主题/Module/Kafka
categories:
  - Kafka
keywords:
  - Kafka
description: Streams API允许将数据流从输入主题转换为输出主题

【Kafka】 Streams API

Streams API允许将数据流从输入主题转换为输出主题。

javadocs中给出了如何使用这个库的示例

关于使用Streams API的其他文档可以在这里找到。

要使用Kafka流，你可以使用以下maven依赖:

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

在使用Scala时，你可以选择包含kafka-streams-scala库。关于在Scala中使用Kafka Streams DSL的附加文档可以在开发者指南中找到。

要使用Kafka Streams DSL for Scala 2.13，你可以使用以下maven依赖:

<dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka-streams-scala_2.13</artifactId>
    <version>3.4.0</version>
</dependency>