回复:kafka connector从指定timestamp开始消费
目前版本不支持,我看1.11版本支持,其实可以自己修改支持 ---原始邮件--- 发件人: "Kyle Zhang"
kafka connector从指定timestamp开始消费
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: