嗯，这个在FLIP-107里会支持，目前没法拿到这些meta数据，可以关注下FLIP-107的进展。
Best,
Leonard Xu
> 在 2020年7月7日，17:26，Dream-底限 <zhan...@akulaku.com> 写道：
>
> hi
> 是的，想以下面这种方式获取
>
> CREATE TABLE MyUserTable (key string,topic string,....,以及其他的数据字段) WITH
> ('connector.type' = 'kafka','connector.version' = '0.11' ,...)
>
>
> On Tue, Jul 7, 2020 at 5:19 PM Leonard Xu <xbjt...@gmail.com> wrote:
>
>> Hi,
>> kafka元数据 是指kafka记录里的 meta数据吗？ 比如kafka自带的timestamp，kafka的key信息。
>> 如果是这些信息的话， Table/SQL API 目前还没办法拿到， FLIP-107[1] 会支持这个事情。
>>
>> 祝好，
>> Leonard Xu
>>
>> [1]
>> https://cwiki.apache.org/confluence/display/FLINK/FLIP-107%3A+Reading+table+columns+from+different+parts+of+source+records
>> <
>> https://cwiki.apache.org/confluence/display/FLINK/FLIP-107:+Reading+table+columns+from+different+parts+of+source+records
>>>
>>
>>> 在 2020年7月7日，17:12，Dream-底限 <zhan...@akulaku.com> 写道：
>>>
>>> kafka元数据
>>
>>
