Re: Flink SQL kafka connector有办法获取到partition、offset信息嘛？

2021-01-21 文章 Leonard Xu
> 看了下，是1.12才开始支持么，1.11是不行的嘛？ 是的，1.11不支持，文档也是有版本的，如果对应版本的文档里没有该功能介绍，那就是不支持的。

Re: Flink SQL kafka connector有办法获取到partition、offset信息嘛？

2021-01-21 文章 gimlee
看了下，是1.12才开始支持么，1.11是不行的嘛？ -- Sent from: http://apache-flink.147419.n8.nabble.com/

Re: Flink SQL kafka connector有办法获取到partition、offset信息嘛？

2021-01-20 文章 HunterXHunter
CREATE TABLE KafkaTable ( `event_time` TIMESTAMP(3) METADATA FROM 'timestamp', `partition` BIGINT METADATA VIRTUAL, `offset` BIGINT METADATA VIRTUAL, `user_id` BIGINT, `item_id` BIGINT, `behavior` STRING ) WITH ( 'connector' = 'kafka', 'topic' = 'user_behavior',

Re: Flink SQL kafka connector有办法获取到partition、offset信息嘛？

2021-01-20 文章 Evan
： gimlee 发送时间： 2021-01-21 11:20 收件人： user-zh 主题： Flink SQL kafka connector有办法获取到partition、offset信息嘛？ 如题，需要获取到kafka的partition、offset进行处理 -- Sent from: http://apache-flink.147419.n8.nabble.com/

Flink SQL kafka connector有办法获取到partition、offset信息嘛？

2021-01-20 文章 gimlee
如题，需要获取到kafka的partition、offset进行处理 -- Sent from: http://apache-flink.147419.n8.nabble.com/