我们可以在 Kafka Stream API 中使用 SQL 查询吗?

Can we use SQL query in Kafka Stream API?

我们可以使用过滤器使用来自 Kafka Stream 的数据吗?从他们的文档中,他们声称我们可以在使用流 API 消费数据的同时应用我们的逻辑。我找不到与此相关的任何示例。

是的,filter 是 Streams API DSL 中的文字方法名称,Kafka Streams 文档页面中的示例很容易获得。

如果要使用SQL过滤,安装KsqlDB或者使用SparkSQL、Flink等