第 10 章 Kafka 客户端
kafka-clients JAR 文件包含 Kafka Producer 和 Consumer API，以及 Kafka AdminClient API。
- Producer API 允许应用程序将数据发送到 Kafka 代理。
- Consumer API 允许应用程序使用 Kafka 代理中的数据。
- AdminClient API 提供用于管理 Kafka 集群的功能，包括主题、代理和其他组件。
10.1. 将 Kafka 客户端作为依赖项添加到 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>将客户端添加到
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-clients</artifactId> <version>2.8.0.redhat-00002</version> </dependency> </dependencies> <!-- ... --> </project>- 构建您的 Maven 项目。
