开发者社区> 问答> 正文

日志服务flink消费sls配置checkpoint第一 是从哪里开始消费

已解决

日志服务flink消费sls配置checkpoint第一 是从哪里开始消费

展开
收起
提个问题! 2024-06-02 15:05:45 38 0
1 条回答
写回答
取消 提交回答
  • 开发者社区问答官方账号
    官方回答
    采纳回答

    当使用Flink消费,从消费的checkpoint获取起始位置时,必须提供消费组名称。除此之外还支持设置一个默认的起始位置,在消费组不存在或者无法从消费组 中获取checkpoint时,将自动切换到默认的起始位置。如下所示:


    configProps.put(ConfigConstants.LOG_CONSUMER_BEGIN_POSITION,Consts.LOG_FROM_CHECKPOINT); configProps.put(ConfigConstants.LOG_CONSUMER_DEFAULT_POSITION,Consts.LOG_END_CURSOR); 


    默认值为Consts.LOG_BEGIN_CURSOR。

    2024-06-02 15:05:46
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载