You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by wei0727wei <we...@163.com> on 2020/02/03 16:09:18 UTC

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

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

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

Posted by Michael Ran <gr...@163.com>.

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

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

Posted by Jark Wu <im...@gmail.com>.

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 <we...@163.com> wrote:

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