search

DTStack / flinkStreamSQL

基于开源的flink，对其实时sql进行扩展；主要实现了流与维表的join，支持原生flink SQL所有的语法
Apache License 2.0
2.02k stars 923 forks source link

kafka source，原生的flink可以读取解析到kafka的元数据比如timestamp。FlinkStreamSql支持读取元数据吗？应该如何操作？ #419

Closed redcheeks666 closed 3 years ago

redcheeks666 commented 3 years ago

kafka source，原生的flink可以读取解析到kafka的元数据比如timestamp。FlinkStreamSql支持读取元数据吗？应该如何操作？

a49a commented 3 years ago

限制FlinkX 1.12可以使用原生插件了