flink kafka sink 源码

在Flink sql进行测试输出， 想把 sql查询的结果Table 转为DataStream 然后进行打印当我们table.toAppendStream[Row]的时候 发现报错其实这个因为我们sql 查的那个动态表 是Mysql 这类源， 他们是可以进行update,delete,insert操作的。对于toAppendStream呢 是仅可以将追加流进行转换输出 比如kafka所以我们使用t

按照官网给出模板进行搭建 创表create table dwd_pv_realtime(ip STRING ,uid STRING ,oid STRING ,`day` STRING) with('connector'='kafka','topic'='flink_test','properties.bootstrap.servers'='x','properties.group.id'...