第3章 Maven プロジェクトにクライアントの依存関係を追加する
Java ベースの Kafka クライアントを開発している場合は、Kafka ストリームを含む Kafka クライアントの Red Hat 依存関係を Maven プロジェクトの pom.xml
ファイルに追加できます。Streams for Apache Kafka では、Red Hat によって構築されたクライアントライブラリーのみがサポートされます。
次のアーティファクトを依存関係として追加できます。
kafka-clients
Kafka の
Producer
、Consumer
、およびAdminClient
API が含まれています。-
Producer
API を使用すると、アプリケーションは Kafka ブローカーにデータを送信できます。 -
Consumer
API を使用すると、アプリケーションは Kafka ブローカーからのデータを消費できるようになります。 -
AdminClient
API は、トピック、ブローカー、その他のコンポーネントを含む、Kafka クラスターを管理するための機能を提供します。
-
kafka-streams
KafkaStreams
API が含まれています。Kafka Streams を使用すると、アプリケーションは 1 つ以上の入力ストリームからデータを受信できます。この API を使用すると、データのストリームに対してマッピング、フィルタリング、結合などの一連のリアルタイム操作を実行できます。Kafka Streams を使用して、結果を 1 つ以上の出力ストリームに書き込むことができます。これは、Red Hat Maven リポジトリーで利用可能な
kafka-streams
JAR パッケージの一部です。
3.1. Kafka クライアントの依存関係を Maven プロジェクトに追加する
Kafka クライアントの Red Hat 依存関係を 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>
kafka-clients
を<dependency>
として Maven プロジェクトのpom.xml
ファイルに追加します。<dependencies> <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>3.7.0.redhat-00004</version> </dependency> </dependencies>
- Maven プロジェクトをビルドして、Kafka クライアントの依存関係をプロジェクトに追加します。