1.3.2. action kamelets
1.3.2.1. 数据过滤 Kamelets
您可以过滤源和 sink 组件间传递的数据,例如防止泄漏敏感数据,或者避免生成不必要的网络费用。
您可以根据以下条件过滤数据:
-
Kafka 主题名称 - 通过配置主题名称 Matches Filter Action Kamelet (
topic-name-matches-filter-action
)来过滤 Kafka 主题的 Kafka 主题的事件,其名称与给定的 Java 正则表达式匹配。如需更多信息,请参阅 过滤特定 Kafka 主题的事件数据。 -
header 键 - 通过配置标头 Filter Action Kamelet (
has-header-filter-action
)来过滤具有给定消息标头的过滤器事件。 -
null 值 - 通过配置 Tombstone Filter Action Kamelet (
is-tombstone-filter-action
)过滤器 tombstone 事件(带有 null 有效负载的事件)。 predicate - 通过配置 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。