如何使用Conduktor过滤Kafka主题中brandName非空的记录?
在Conduktor中过滤Kafka记录:筛选指定字段不为空的方法
要筛选.billingAccounts[0].clientContracts[0].brandName字段不为null的Kafka记录,你可以在Conduktor的「高级-字段选择」过滤器里使用否定匹配语法,具体配置如下:
- 第一行(字段路径):
.billingAccounts[0].clientContracts[0].brandName - 第二行(匹配规则):
!= null
配置完成后,过滤器就会只保留该字段值不为null的记录。
另外需要注意:
- 这里的
[0]是取数组的第一个元素,如果你的业务场景中需要匹配数组内任意位置的brandName不为null的情况,可尝试将字段路径改为billingAccounts[*].clientContracts[*].brandName,再配合!= null使用(部分Conduktor版本对通配符数组的支持需自行验证)。 - 如果记录中不存在
.billingAccounts[0].clientContracts[0]这个路径(比如数组为空),这类记录会被过滤器自动排除,因为字段路径不存在,自然不满足「字段值不为null」的条件。
内容的提问来源于stack exchange,提问作者Tom Mc
相关产品推荐
相关产品推荐

