开发者社区> 问答> 正文

求问为什么KafkaDynamicSource 在批模式下不能运行

afka在我们这边场景上除了用来存放实时流式数据,还会用作临时大数据量的存储,主要用于: 

1. 数据同步时,将全量数据同步到一个临时的kafka中,增量数据持续性同步到kafka中,目前我们都使用流模式消费其中的数据,就会有手动停止,或者借助指标等自动停止流式任务 

  1. 数据恢复时 

  2. 临时查看某个时间区间的数据 

如果批模式 sql能够完成这些事情的话那该多好*来自志愿者整理的flink邮件归档

展开
收起
CCCC 2021-12-02 14:51:08 496 0
1 条回答
写回答
取消 提交回答
  • 现在Flink 走的是流批一体, 为什么说 Kafka 不支持批模式呢?*来自志愿者整理的FLINK邮件归档

    2021-12-02 16:03:30
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink中的两类新型状态存储 立即下载
十分钟上线-使用函数计算构建支付宝小程序服务 立即下载
4个迭代,从批量交...1573957773.pdf 立即下载