第 3 章 将客户端依赖项添加到 Maven 项目中
如果要开发基于 Java 的 Kafka 客户端,您可以将包括 Kafka 客户端的红帽依赖项(包括 Kafka Streams)添加到 Maven 项目的 pom.xml
文件中。对于 Apache Kafka,只支持由红帽构建的客户端库。
您可以将以下工件作为依赖项添加:
kafka-clients
包含 Kafka
Producer
、Consumer
和AdminClient
API。-
Producer
API 可让应用程序将数据发送到 Kafka 代理。 -
Consumer
API 可让应用程序消耗 Kafka 代理中的数据。 -
AdminClient
API 提供了管理 Kafka 集群的功能,包括主题、代理和其他组件。
-
kafka-streams
包含
KafkaStreams
API。Kafka Streams 可让应用程序从一个或多个输入流接收数据。您可以使用此 API 对数据流运行一系列实时操作,如映射、过滤和加入。您可以使用 Kafka Streams 将结果写入一个或多个输出流。它是 Red Hat Maven 存储库中提供的
kafka-streams
JAR 软件包的一部分。
3.1. 在 Maven 项目中添加 Kafka 客户端依赖项
将 Kafka 客户端的红帽依赖项添加到 Maven 项目中。
先决条件
-
具有现有
pom.xml
的 Maven 项目。
流程
将 Red Hat Maven 存储库添加到 Maven 项目的
pom.xml
文件的 <repositories
> 部分。<repositories> <repository> <id>redhat-maven</id> <url>https://maven.repository.redhat.com/ga/</url> </repository> </repositories>
<repositories> <repository> <id>redhat-maven</id> <url>https://maven.repository.redhat.com/ga/</url> </repository> </repositories>
Copy to Clipboard Copied! 将
kafka-clients
作为 <dependency
> 添加到 Maven 项目的pom.xml
文件中。<dependencies> <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>3.8.0.redhat-00007</version> </dependency> </dependencies>
<dependencies> <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>3.8.0.redhat-00007</version> </dependency> </dependencies>
Copy to Clipboard Copied! - 构建 Maven 项目,将 Kafka 客户端依赖项添加到项目中。