开发者社区> 问答> 正文

flink + rocketmq从指定Offsets启动有人做过吗

转自钉钉群21789141:flink + rocketmq从指定Offsets启动有人做过吗

展开
收起
赵慧@ApacheFlink中文社区 2019-02-21 17:12:29 4418 0
1 条回答
写回答
取消 提交回答
  • 火锅:Offsets 从外部参数传入? 还是你checkpoint 里面有

    问:外部

    火锅:你在 initializeState 里面去实现下呢,启动的时候,这里初始化你的offset ,根据你的值处理。你只初始化参数,从open 方法也行

    2019-07-17 23:28:58
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
RocketMQ Client-GO 介绍 立即下载
RocketMQ Prometheus Exporter 打造定制化 DevOps 平台 立即下载
基于 RocketMQ Prometheus Exporter 打造定制化 DevOps 平台 立即下载