回复:kafka connector从指定timestamp开始消费

2020-06-11 文章 claylin
目前版本不支持,我看1.11版本支持,其实可以自己修改支持 ---原始邮件--- 发件人: "Kyle Zhang"

kafka connector从指定timestamp开始消费

2020-06-11 文章 Kyle Zhang
Hi, kafka connector ddl能不能像flinkKafkaConsumer.setStartFromTimestamp(xx)一样从指定timestamp开始消费,我看文档里只提到了earliest-offset,latest-offset,group-offsets,specific-offsets CREATE TABLE MyUserTable ( ... ) WITH ( 'connector.type' = 'kafka', 'connector.version' = '0.11', -- required: