Kafka KSQLDB -计算输入公式

Question

我正在使用Kafka KsqlDB。我正在尝试创建一个简单的表过滤器(例如，SELECT * FROM Table WHERE formula)。问题是过滤器公式是在输入数据(来自Kafka Connect的CSV文件数据)上。所以这个问题的要点是使用KsqlDB外部的公式，然后将该公式放在WHERE子句中。有可能做到这一点吗？

Answer 1

我不确定我是否完全理解了你的问题。如果我这样做了，对您的建议是，您可以使用CSV SMT，并在DropFilter文件上设置ksql源连接器。