美文网首页
flinkkafka的参数

flinkkafka的参数

作者: 神呐_宽恕我把 | 来源:发表于2020-11-05 11:07 被阅读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

    相关文章

      网友评论

          本文标题:flinkkafka的参数

          本文链接:https://www.haomeiwen.com/subject/zuvgvktx.html