如何在Lenses 3.2中查询含指定字段的Kafka消息？

你之前用EXISTS(field_name)的写法不对，Lenses SQL里的EXISTS函数是用来处理子查询的，不能直接用来检查字段是否存在，这就是它没生效的原因。

给你两种场景下的正确查询方式：

1. 消息体是JSON这类半结构化格式 #

用HAS_FIELD函数直接检查字段是否存在，语法如下：

USE `kafka`;
SELECT * FROM topic_name WHERE HAS_FIELD(field_name);

如果是嵌套字段（比如user.profile.email），可以这样写：

USE `kafka`;
SELECT * FROM topic_name WHERE HAS_FIELD(user, 'profile.email');

2. 消息使用Avro等带Schema的格式 #

如果你的Kafka Topic用了Schema Registry管理的结构化Schema（比如Avro），且存在多版本Schema，要筛选包含目标字段的消息，用SCHEMA_FIELD_EXISTS函数：

USE `kafka`;
SELECT * FROM topic_name WHERE SCHEMA_FIELD_EXISTS('field_name');

另外补充：如果你的消息结构比较简单，也可以直接用field_name IS NOT NULL来判断——因为Lenses在处理不存在的字段时会返回NULL，所以这个判断也能间接筛选出存在该字段且有值的消息，但如果字段存在但值为NULL，这条也会被排除，根据你的需求选择即可。

内容的提问来源于stack exchange，提问作者AAV