第 12 章 添加 Kafka Streams API


Kafka Streams API 允许应用程序从一个或多个输入流接收数据,执行复杂的操作,如映射、过滤或加入,并将结果写入一个或多个输出流。它是 Red Hat Maven 存储库中可用的 kafka-streams JAR 软件包的一部分。

此流程演示了如何将 AMQ Streams Java 客户端作为依赖项添加到 Maven 项目中。

先决条件

  • 含有现有 pom.xml 的 Maven 项目。

流程

  1. 将 Red Hat Maven 存储库添加到 pom.xml 文件的 & lt;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>
    Copy to Clipboard Toggle word wrap
  2. 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>3.3.1.redhat-00008</version>
            </dependency>
        </dependencies>
    
        <!-- ... -->
    </project>
    Copy to Clipboard Toggle word wrap
  3. 构建 Maven 项目。
返回顶部
Red Hat logoGithubredditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务,以及可以信赖的内容,帮助红帽用户创新并实现他们的目标。 了解我们当前的更新.

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情,请参阅红帽博客.

關於紅帽

我们提供强化的解决方案,使企业能够更轻松地跨平台和环境(从核心数据中心到网络边缘)工作。

Theme

© 2025 Red Hat