Apache Kafkaアダプタの機能

「Apache Kafkaアダプタ」の機能

「Apache Kafkaアダプタ」を使用すると、Apache Kafkaメッセージング・システムに接続する統合をOracle Integrationに作成できます。「Apache Kafkaアダプタ」は、Oracle IntegrationからApache Kafka分散パブリッシュ/サブスクライブ・メッセージング・システムに接続し、Kafkaトピックからのメッセージのパブリッシュおよび消費を許可します。

「Apache Kafkaアダプタ」には、次の利点があります:

Apache Kafkaメッセージング・システムへの接続を確立し、メッセージの公開および消費を有効にします。
Kafkaトピックからのメッセージをコンシュームし、起動(アウトバウンド)方向でKafkaトピックへのメッセージを生成します。

ノート:
インバウンド方向のメッセージ消費は、オンプレミス接続エージェントの使用でのみサポートされます。
トリガー(インバウンド)方向の指定された頻度に基づいて、トピックからのメッセージを消費します。
アダプタ・エンドポイント構成ウィザード(メッセージがパブリッシュされて消費されるトピックおよびパーティション)を使用して、使用可能なメタデータを参照できます。
コンシューマ・グループをサポートします。
サポートされるヘッダー。
次のメッセージ構造がサポートされます:
- Avroスキーマ
  このスキーマは、次のシナリオに適用できます:
  - メッセージの生成と消費 - 接続の起動(直接接続と接続エージェントの両方でサポートされています)
  - メッセージの消費 - トリガー接続(接続エージェントでのみサポートされます)
- サンプルJSON
- XMLスキーマ(XSD)およびスキーマのアーカイブ・アップロード
- サンプルXML
次のセキュリティ・ポリシーがサポートされます:
- 簡易認証/セキュリティ・レイヤー・プレーン(SASL/PLAIN)
- SSL経由のSASLプレーン
- TLS
- 相互TLS
SSLを介したApache Kafkaメッセージング・システムへの直接接続をサポートします。
接続エージェントを介したオンプレミスApache Kafkaメッセージング・システムへの接続をサポートします。
Confluent Kafkaプラットフォームとの統合をサポートして、メッセージを生成および消費します。
オプションで、Kafkaプロデューサをトランザクションとして構成できます。これにより、アプリケーションは複数のパーティションにメッセージを原子的に送信できます。「トピック&パーティション・ページ」を参照してください。

http://kafka.apache.org/を参照してください。

「Apache Kafkaアダプタ」は、Oracle Integrationに含まれている多数の事前定義済アダプタのいずれかです。「Apache Kafkaアダプタ」をトリガー接続として構成し、Oracle Integrationの統合で起動接続を構成できます。