好的 On Tue, Jul 7, 2020 at 5:30 PM Leonard Xu <xbjt...@gmail.com> wrote:
> 嗯,这个在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元数据 > >> > >> > >