1. Homepage
  2. Apache Kafka Connector (4.7)

  3. Apache Kafka Connector の XML と Maven のサポート

All Connectors

Apache Kafka 4.7 XML および Maven サポート - Mule 4

Anypoint Studio の XML エディターまたはテキストエディターから XML で Mule アプリケーションを手動でコーディングする場合、XML Mule フローと Apache Maven ​pom.xml​ ファイルに参照ステートメントを追加して、アプリケーションで Apache Kafka 用 Anypoint Connector (Apache Kafka Connector) にアクセスできます。

Anypoint Studio を使用すると、この手動プロセスを回避できます。Apache Kafka Connector を Studio に追加すると、Studio によって自動的に XML コードに Apache Kafka Connector の名前空間とスキーマの場所が入力され、pom.xml ファイルに連動関係が追加されます。

コネクタの名前空間の追加

次のコードを設定 XML のヘッダーの ​<mule>​ タグ内に貼り付けます。

http://www.mulesoft.org/schema/mule/kafka
http://www.mulesoft.org/schema/mule/kafka/current/mule-kafka.xsd

次の例は、​<mule>​ XML ブロック内に名前空間ステートメントが配置される方法を示しています。

<mule xmlns:kafka="http://www.mulesoft.org/schema/mule/kafka"
	xmlns:ee="http://www.mulesoft.org/schema/mule/ee/core"
	xmlns:http="http://www.mulesoft.org/schema/mule/http"
	xmlns:file="http://www.mulesoft.org/schema/mule/file"
	xmlns="http://www.mulesoft.org/schema/mule/core"
	xmlns:doc="http://www.mulesoft.org/schema/mule/documentation"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://www.mulesoft.org/schema/mule/core
	http://www.mulesoft.org/schema/mule/core/current/mule.xsd
	http://www.mulesoft.org/schema/mule/file
	http://www.mulesoft.org/schema/mule/file/current/mule-file.xsd
	http://www.mulesoft.org/schema/mule/http
	http://www.mulesoft.org/schema/mule/http/current/mule-http.xsd
	http://www.mulesoft.org/schema/mule/ee/core
	http://www.mulesoft.org/schema/mule/ee/core/current/mule-ee.xsd
	http://www.mulesoft.org/schema/mule/kafka
	http://www.mulesoft.org/schema/mule/kafka/current/mule-kafka.xsd">

POM ファイルの連動関係の追加

Apache Maven ​pom.xml​ ファイルは Anypoint Studio によって生成され、Mule アプリケーションの連動関係が含まれます。Mule アプリケーションを手動でコーディングする場合、次の XML スニペットを ​pom.xml​ ファイルに含めてこのコネクタにアクセスできるようにします:

<dependency>
  <groupId>com.mulesoft.connectors</groupId>
  <artifactId>mule-kafka-connector</artifactId>
  <version>x.x.x</version>
  <classifier>mule-plugin</classifier>
</dependency>

x.x.x​ を使用しているコネクタに対応するバージョンに置き換えます。

最新の ​pom.xml​ ファイル情報を取得するには、​ Anypoint Exchange​ でコネクタにアクセスし、​[Dependency Snippets (連動関係スニペット)]​ をクリックします。

次のステップ

名前空間および ​pom.xml​ ファイルを完了したら、Apache Kafka の​例​を試すことができます。

関連情報