问如何在ElasticSearch Sink连接器中过滤数据？
EN

Stack Overflow用户

提问于 2022-01-18 17:44:39

回答 1查看 112关注 0票数 0

我正在使用来自合流审计日志集群的数据，并使用弹性搜索接收器连接器为弹性搜索创建索引。我正在获取内部集群所有环境的数据。我想在弹性接收器连接器级别上应用过滤器，这样我就可以根据我在连接器级别提供的集群ID过滤我的数据。

有人知道如何将过滤器应用于弹性搜索水槽连接器吗？

谢谢!

elasticsearch

confluent-cloud

回答 1

Stack Overflow用户

回答已采纳

发布于 2022-01-31 17:00:37

最后，我想出了我问题的答案如下。您可以使用变换过滤数据，并根据数据应用regex。

"transforms": "dataFilterByClusterId",
"transforms.dataFilterByClusterId.type": "io.confluent.connect.transforms.Filter$Value",
"transforms.dataFilterByClusterId.filter.condition": "$[?(@.subject =~ /.*YourClusterID/)]",
"transforms.dataFilterByClusterId.filter.type": "include"

票数 0

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/70760124

复制

相似问题

问如何在ElasticSearch Sink连接器中过滤数据？
EN

回答 1

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问如何在ElasticSearch Sink连接器中过滤数据？EN

回答 1

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问如何在ElasticSearch Sink连接器中过滤数据？
EN