Apache Kafka Connector 4.5

Apache Kafka 用 Anypoint Connector (Apache Kafka Connector) を使用すると、Apache Kafka メッセージングシステムとやりとりでき、Mule Runtime Engine (Mule) を使用した Mule アプリケーションと Kafka クラスター間のシームレスなインテグレーションを実現できます。

互換性に関する情報は「Apache Kafka Connector リリースノート」を参照してください。

始める前に

アプリケーションを作成する前に、次の作業を行う必要があります。

  • Apache Kafka の対象リソースおよび Anypoint Platform へのアクセス権を取得する

  • Anypoint Studio を使用した Mule アプリケーションの作成方法を理解する

  • Studio に表示される項目の値を取得するために Apache Kafka へのアクセス権を取得する

ユースケース

Apache Kafka は多目的アプリケーションです。Apache Kafka とのインテグレーションには、一般的に使用されるアプリケーションが使用されます。

次のようなユースケースがあります。

  • 病院の患者が必要なケアをタイムリーに受けられるようにするインテグレーションアプリケーション
    この例として、患者の許可を求める緊急の要求を処理する病院のサーバーが挙げられます。要求は、措定された条件 (患者の状態の重篤度や患者の治療に対応できるスタッフなど) によって決まる優先度順に並び替えられます。このシナリオでは、アプリケーションは、キューを介して送信されるメッセージの順序と羃等性を使用して、受信した順序で Apache Kafka メッセージを処理します。

  • 時間的制約のあるアプリケーション
    この例として、Apache Kafka システムを使用して最新のニュースを配信するニュースルームが挙げられます。Apache Kafka キューから最新のニュースを読み取って取得するには、まずキューの末尾から読み取ることが必要になる場合があります。

  • Apache Kafka によって提供される情報を使用する複数のアプリケーション
    たとえば、ある百貨店が Web サイトアクティビティトラッカーを使用してオンラインショッピング体験を改善するとします。生成されたデータは複数の部門に送信されてさまざまな計算が行われます。各部門は、受信した情報を確認して、顧客が探している商品に関する最新情報を入手し、それに応じておすすめを提案します。

対象者

次のステップ

前提条件を満たしたら、​Anypoint Studio​ でアプリケーションを作成できます。