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