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

[wei.wei]

Flink Sql中Kafka-Source只看到了关于Value的Deserialize，要怎么获取对应的Key及meta(offset, topic, partition)信息呢？

[Jark]

Hi,

目前 Flink SQL 还不支持访问 key 及 meta，不过这功能已经在计划中了，有望在1.11 中支持。
我建了个 issue 来追踪这个需求：https://issues.apache.org/jira/browse/FLINK-15869

Best,
Jark

On Tue, 4 Feb 2020 at 00:10, wei0727wei <[hidden email]> wrote:

> Flink Sql中Kafka-Source只看到了关于Value的Deserialize，要怎么获取对应的Key及meta(offset,
> topic, partition)信息呢？

[Michael Ran]

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