我给一个Kafka主题发送了注入线协议点。我能从Kafka的cli中读到这些观点。现在我想在xdb中插入Kafka主题的所有要点。我配置了kafka influxdb接收器连接器，将数据推入influxdb。我无法找出kql查询来实现这一点。
我试过了
插入*来自流入主题
希望它能将所有内容从主题推到XDB，但我遇到了解析错误。 Caused by: java.lang.IllegalStateException: failed to parse at line 1 due to mismatched input '*' expecting INTO at com.datamountaineer.kcql.Kcql$1.syntaxError(Kcql.java:330) at org.antlr.v4.runtime.ProxyErrorListener.syntaxError(ProxyErrorListener.java:41) at org.antlr.v4.runtime.Parser.notifyErrorListeners(Parser.java:544) at org.antlr.v4.runtime.DefaultErrorStrategy.reportInputMismatch(DefaultErrorStrategy.java:299) at org.antlr.v4.runtime.DefaultErrorStrategy.reportError(DefaultErrorStrategy.java:124) 注意：我在kafka主题中已经有了行协议格式的数据，所以我不需要选择特定的字段。目前该主题只有一个度量的数据，将来可能有多个度量的数据。
我阅读了kql的文档|https://lenses.stream/1.0/lenses/connectors/kcql.html#kcql 但仍然无法确定正确的查询是什么样子。请帮我填写查询表。