apache-kafka - Kafka KSQLDB - 计算输入公式

Question

我正在使用 Kafka KsqlDB。我正在尝试制作一个简单的表格过滤器（例如，SELECT * FROM table WHERE 公式）。问题是过滤器公式在输入数据（来自 Kafka Connect 的 CSV 文件数据）上。所以这个问题的重点是使用KsqlDB外部的公式，然后将该公式放入WHERE子句中。是否有可能做到这一点？

标签： apache-kafkaconfluent-platform

Answer 1

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