第 11 章 Kafka Streams API 概述
Kafka Streams API 允许应用程序从一个或多个输入流接收数据，执行映射、过滤或加入等复杂操作，并将结果写入一个或多个输出流。它是 Red Hat Maven 存储库中提供的 kafka-streams JAR 软件包的一部分。
11.1. 将 Kafka Streams API 添加为 Maven 项目的依赖项
此流程演示了如何将 AMQ Streams Java 客户端添加为 Maven 项目的依赖项。
先决条件
-
具有现有
pom.xml的 Maven 项目。
流程
将 Red Hat Maven 存储库添加到
pom.xml文件的<repositories>部分。<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <!-- ... --> <repositories> <repository> <id>redhat-maven</id> <url>https://maven.repository.redhat.com/ga/</url> </repository> </repositories> <!-- ... --> </project>将
kafka-streams添加到pom.xml文件的<dependencies>部分。<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <!-- ... --> <dependencies> <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-streams</artifactId> <version>2.8.0.redhat-00002</version> </dependency> </dependencies> <!-- ... --> </project>- 构建您的 Maven 项目。
