1.3.2. action kamelets

1.3.2.1. 数据过滤 Kamelets

您可以过滤源和接收器组件之间传递的数据,例如防止泄漏敏感数据,或者避免生成不必要的网络费用。

您可以根据以下条件过滤数据:

  • Kafka 主题名称 - 通过配置 Topic Name Matches Filter Action Kamelet(topic-name-matches-filter-action)的 Kafka 主题和名称与 Java 正则表达式匹配的事件。如需更多信息,请参阅 过滤特定 Kafka 主题的事件数据
  • 标头键 - 通过配置 Header Filter Action Kamelet(with-header-filter-action)来过滤具有给定邮件标头的事件。
  • null - 通过配置 Tombstone Filter Action Kamelet(is-tombstone-filter-action)来过滤事件(带有 null 有效负载的事件)。
  • predicate - 通过配置 Predicate Filter Action Kamelet(predicate-filter-action),根据给定的 JSON 路径表达式过滤事件。predicate-filter-action Kamelet 要求您在 Kamelet Binding 中设置以下 Builder trait 配置属性:

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

数据过滤 Kamelets 使用 JSON 数据开箱即用(即,Content-Type 标头设置为 application/json 时)。如果事件数据使用 JSON 以外的格式,您必须通过添加 deserialize-action(例如: protobuf-deserialize-actionavro-deserialize-action)在操作操作和序列化步骤前转换数据格式(如 protobuf-serialize-actionavro-serialize-action)。有关转换连接中数据格式的更多信息,请参阅数据转换 Kamelets