我们可以使用过滤器使用来自 Kafka Stream 的数据吗？从他们的文档中，他们声称我们可以在使用流 API 消费数据的同时应用我们的逻辑。我找不到任何相关的样本。
是的，filter是 Streams API DSL 中的文字方法名称，示例可在 Kafka Streams 文档页面中轻松获得。
filter
如果要使用 SQL 进行过滤，安装 KsqlDB 或使用 SparkSQL、Flink 等。
本文收集自互联网，转载请注明来源。
如有侵权，请联系 [email protected] 删除。
点击生成二维码
我来说两句