第11章 Kafka クライアント
kafka-clients JAR ファイルには、Kafka Producer および Consumer API と、Kafka AdminClient API が含まれています。
- Producer API は、アプリケーションが Kafka ブローカーにデータを送信できるようにします。
- Consumer API は、アプリケーションが Kafka ブローカーからデータを消費できるようにします。
- AdminClient API は、トピック、ブローカー、およびその他のコンポーネントなどの Kafka クラスターを管理するための機能を提供します。
11.1. Maven プロジェクトへの依存関係としての Kafka クライアントの追加
この手順では、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.6.0.redhat-00004</version> </dependency> </dependencies> <!-- ... --> </project>- Maven プロジェクトをビルドします。
