flinkkafka的参数

2020-11-05  本文已影响0人  神呐_宽恕我把

earliest-offset:从topic的最开始读

latest-offset:从当前启动消费者传过来最新的数据读

group-offsets:从消费者组上次记录的偏移量那里开始读

timestamp:指定一个时间戳,以毫秒为单位,从这个时间开始读,这个时间必须必当前时间小scan.startup.timestamp-millis:1601186100000

specific-offsets:指定各个分区的偏移量,从指定的偏移量那里开始读scan.startup.specific-offsets:partition:0,offset:42;partition:1,offset:300

上一篇下一篇

猜你喜欢

热点阅读