1.3.2. action kamelets


1.3.2.1. 数据过滤 Kamelets

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

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

  • Kafka 主题名称 - 通过配置 Topic Name Matches Filter Kamelet (topic-name-matches-filter-action)的名称带有与给定 Java 正则表达式匹配的 Kafka 主题的 Filter 事件。如需更多信息,请参阅 为特定 Kafka 主题过滤事件数据
  • 标头键 - 通过配置 Header Filter Action Kamelet (has-header-filter-action)来带有给定消息标头的过滤器事件。
  • null value - 通过配置 Tombstone Filter Action Kamelet (用于过滤 tombstone-filter-action)的过滤器 tombstone 事件(带有 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 以外的格式,您必须通过添加反序列化步骤(例如,protobuf-deserialize-actionavro-deserialize-action)在操作操作和序列化步骤前转换数据格式(例如,protobuf-serialize-actionavroserialize-action)。有关在连接中转换数据格式的更多信息,请参阅 数据转换 Kamelets

Red Hat logoGithubRedditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务,以及可以信赖的内容,帮助红帽用户创新并实现他们的目标。

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情,请参阅红帽博客.

關於紅帽

我们提供强化的解决方案,使企业能够更轻松地跨平台和环境(从核心数据中心到网络边缘)工作。

© 2024 Red Hat, Inc.