「Apache Kafkaアダプタ」の機能
「Apache Kafkaアダプタ」を使用すると、Apache Kafkaメッセージング・システムに接続する統合をOracle Integrationに作成できます。 「Apache Kafkaアダプタ」は、Oracle IntegrationからApache Kafka分散パブリッシュ/サブスクライブ・メッセージング・システムに接続し、Kafkaトピックからのメッセージのパブリッシュおよび消費を許可します。
「Apache Kafkaアダプタ」には、次の利点があります:
- Apache Kafkaメッセージング・システムへの接続を確立し、メッセージの公開および消費を有効にします。
- Kafkaトピックからのメッセージをコンシュームし、起動(アウトバウンド)方向でKafkaトピックへのメッセージを生成します。
- トリガー(インバウンド)方向の指定された頻度に基づいて、トピックからのメッセージを消費します。
ノート:
インバウンド方向のメッセージ消費は、オンプレミス接続エージェントの使用でのみサポートされます。 - Apache KafkaストリーミングAPIを使用して、Kafkaクラスタのトピックからデータを読み取ります。
- アダプタ・エンドポイント構成ウィザード(メッセージがパブリッシュされて消費されるトピックおよびパーティション)を使用して、使用可能なメタデータを参照できます。
- トリガー操作のメッセージのデバッチをサポートします。
- コンシューマ・グループをサポートします。
- サポートされるヘッダー。
- 次のメッセージ構造がサポートされます:
- サンプルJSON
- XMLスキーマ(XSD)およびスキーマのアーカイブ・アップロード
- サンプルXML
- Avroスキーマ
- 不透明
これらのスキーマは、次のシナリオに適用されます:
- メッセージの生成と消費 - 接続の起動(直接接続と接続エージェントの両方でサポートされています)
- メッセージの消費 - トリガー接続(接続エージェントでのみサポートされます)
- 接続性エージェントとの相互TLSセキュリティ・ポリシーを使用したAmazon MSKへの接続をサポートします。
- プライベート・エンドポイントを使用した仮想クラウド・ネットワーク(VCN)プライベート・サブネットにあるプライベート・リソースへの接続をサポートします。 「Oracle Integration 3のプロビジョニングと管理」と「エンドポイント・アクセス・タイプの構成」の「プライベート・リソースへの接続」を参照してください。 このタイプの接続では、接続エージェントは使用されません。
- 接続エージェントを使用する場合と使用しない場合の、「Apache Kafkaアダプタ」での処理に関するメッセージのポーリングをサポートします。 「接続エージェントを使用しないインバウンド・ポーリングの実行」を参照してください。
- 次のセキュリティ・ポリシーがサポートされます:
- SASL OAuth (クライアント資格証明)
- SSL経由のSASLプレーン
- TLS
- 相互TLS
- SASL OAuth (JWTクライアント・アサーションを使用したクライアント資格証明)
- 簡易認証/セキュリティ・レイヤー・プレーン(SASL/PLAIN)
- SSLを介したApache Kafkaメッセージング・システムへの直接接続をサポートします。
- 接続エージェントを介したオンプレミスApache Kafkaメッセージング・システムへの接続をサポートします。
- Confluent Kafkaプラットフォームとの統合をサポートして、メッセージを生成および消費します。
- オプションで、Kafkaプロデューサをトランザクションとして構成できます。 これにより、アプリケーションは複数のパーティションにメッセージを原子的に送信できます。 「トピック&パーティション・ページ」を参照してください。
- SASL OAuth (クライアント資格証明)およびSASL OAuth (JWTクライアント・アサーションを使用したクライアント資格証明)セキュリティ・ポリシーを使用したAzureイベント・ハブへの接続をサポートします。 この接続により、既存の「Apache Kafkaアダプタ」機能をAzureイベント・ハブ統合で使用できるようになります。 「Azureイベント・ハブのApache Kafka」を参照してください。
http://kafka.apache.org/を参照してください。
「Apache Kafkaアダプタ」は、Oracle Integrationの統合でトリガー接続および呼出し接続として構成できます。 「Apache Kafkaアダプタ」は、Oracle Integrationに含まれる多数の事前定義済アダプタの1つです。 Oracle Help Centerの「アダプタ」ページを参照してください。