开发者社区 问答 正文

Flink程序中的消费策略有哪些呢?

Flink程序中的消费策略有哪些呢?

展开
收起
游客vqgchj4kfdzsu 2021-12-08 22:00:26 461 分享 版权
1 条回答
写回答
取消 提交回答
  • setStartFromGroupOffsets()【默认消费策略】

    默认读取上次保存的offset信息 如果是应用第一次启动,读取不到上次的offset信息,则会根据这个参数auto.offset.reset的值来进行消费数据

    setStartFromEarliest() 从最早的数据开始进行消费,忽略存储的offset信息

    setStartFromLatest() 从最新的数据进行消费,忽略存储的offset信息

    setStartFromSpecificOffsets(Map<KafkaTopicPartition, Long>) 从指定位置进行消费

    2021-12-08 22:48:35
    赞同 展开评论