开发者社区> 问答> 正文

Flink中RocketMQ能否设定消息的读取方式如kafka的scan.startup.mo...

已解决

Flink中RocketMQ能否设定消息的读取方式如kafka的scan.startup.mode= latest-offset

展开
收起
提个问题 2024-05-30 12:03:21 53 0
1 条回答
写回答
取消 提交回答
  • 开发者社区问答官方账号
    官方回答
    采纳回答
    Rocketmq目前无法像kafka那样设置scan.startup.mode' = 'latest-offset',可以设置数据的消费位点startTimeMs,详情请参考文档
    2024-05-30 12:03:22
    赞同 展开评论 打赏
归属于问产品:
实时计算 Flink版
进入专区
问答排行榜
最热
最新

相关电子书

更多
基于 Flink SQL + Paimon 构建流式湖仓新方 立即下载
基于 Flink CDC 打造 企业级实时数据集成方案 立即下载
李劲松|Flink Table Store 典型应用场景 立即下载