1.3.2. アクション kamelets

1.3.2.1. データフィルターリング Kamelets

たとえば、機密データの漏えいや不要なネットワーク課金の生成を防ぐためやに、ソースとシンクコンポーネント間で渡されるデータをフィルターリングすることができます。

以下の基準に基づいてデータをフィルターできます。

  • Kafka トピック名: Topic Name Matches Filter Action Kamelet (topic-name-matches-filter-action) を設定して、指定の Java 正規表現に一致する名前を持つ Kafka トピックのイベントをフィルターします。詳細は、特定の Kafka トピックのイベントデータの絞り込み を参照してください。
  • ヘッダーキー: Header Filter Action Kamelet (has-header-filter-action) を設定して、特定のメッセージヘッダーを持つイベントをフィルターします。
  • null 値: Tombstone Filter Action Kamelet (is-tombstone-filter-action) を設定して、null ペイロードを持つイベントであるトゥームストーンイベントをフィルターします。
  • 述語: Predicate Filter Action Kamelet (predicate-filter-action) を設定して、指定の JSON パス式に基づいてイベントをフィルターします。predicate-filter-action Kamelet では、Kamelet Binding に以下の Builder トレイト 設定プロパティーを設定する必要があります。

    spec:
      integration:
        traits:
          builder:
            configuration:
              properties:
               - "quarkus.arc.unremovable-types=com.fasterxml.
                    jackson.databind.ObjectMapper"
注記

データフィルターリング Kamelets は、JSON データ (つまり、Content-Type ヘッダーが application/json に設定されている場合) で追加設定なしで機能します。イベントデータが JSON 以外の形式を使用する場合は、操作アクションおよびその後のシリアライズステップ (例: protobuf-deserialize-action または avro-deserialize-action) の前にデシリアライズステップ (例: protobuf-serialize-action または avro-serialize-action) を追加して、データの形式を変換する必要があります。接続のデータ形式を変換する方法は、データ変換 Kamelets を参照してください。