Re:Flink Sql中Kafka-Source怎么获取Key值

Mon, 03 Feb 2020 23:56:02 -0800 

source从新 订阅，作为新字段加入 字段列表里面 可行不？  我们改了source，对binlog 进行处理，源头很多字段 都加入进去。下游让SQL 处理
在 2020-02-04 00:09:18，"wei0727wei" <[email protected]> 写道：
>Flink Sql中Kafka-Source只看到了关于Value的Deserialize，要怎么获取对应的Key及meta(offset, topic, 
>partition)信息呢？

回复