当前位置: 首页 > news >正文

【大数据面试题】32 Flink 怎么重复读 Kafka?

一步一个脚印,一天一道面试题

首先,为什么要读过的 Kafka 数据重写读一次呢?什么场景下要怎么做呢?

答:当任务失败,从检查点Checkpoint 开始重启时,检查点的数据是之前的了,就需要跟Kafka申请回退,从Checkpoint版的 offset 的数据读,会有一点重复消费

---------------------- 分割线 ----------------------在这里插入图片描述---------------------- 分割线 ----------------------

那怎么重复读 Kafka 呢?
Kafka 提交之前的 offset 即可

我是近未来,祝你变得更强!

相关文章:

  • SpringBoot自动装配原理是什么?
  • 互联网医院开发:引领智慧医疗新时代
  • Mac安装配置maven
  • KDE-Ambari-Metrics-Collector问题排查解决手册
  • 企业防泄密软件有哪些,哪个排名最好
  • 指针数组与数组指针的理解
  • 前端基础:1-2 面向对象 + Promise
  • 4、设计模式之工厂模式
  • C语言常用的内存操作函数
  • 打豆豆game
  • 带你玩转OpenHarmony AI:打造智能语音子系统
  • SpringBoot基础详解
  • 指针变量加1为什么地址加了4?
  • Python01:初入Python(Mac)
  • 【计算机视觉(3)】
  • php的引用
  • 【MySQL经典案例分析】 Waiting for table metadata lock
  • 【腾讯Bugly干货分享】从0到1打造直播 App
  • Cookie 在前端中的实践
  • Fabric架构演变之路
  • HTTP 简介
  • Java知识点总结(JDBC-连接步骤及CRUD)
  • python3 使用 asyncio 代替线程
  • Zsh 开发指南(第十四篇 文件读写)
  • 从零开始学习部署
  • - 概述 - 《设计模式(极简c++版)》
  • 基于webpack 的 vue 多页架构
  • 判断客户端类型,Android,iOS,PC
  • 如何在 Tornado 中实现 Middleware
  • 深入浏览器事件循环的本质
  • 基于django的视频点播网站开发-step3-注册登录功能 ...
  • 如何用纯 CSS 创作一个货车 loader
  • ​【数据结构与算法】冒泡排序:简单易懂的排序算法解析
  • ​TypeScript都不会用,也敢说会前端?
  • ​卜东波研究员:高观点下的少儿计算思维
  • # Java NIO(一)FileChannel
  • # windows 运行框输入mrt提示错误:Windows 找不到文件‘mrt‘。请确定文件名是否正确后,再试一次
  • ######## golang各章节终篇索引 ########
  • #nginx配置案例
  • #进阶:轻量级ORM框架Dapper的使用教程与原理详解
  • #预处理和函数的对比以及条件编译
  • (31)对象的克隆
  • (ibm)Java 语言的 XPath API
  • (zt)基于Facebook和Flash平台的应用架构解析
  • (多级缓存)多级缓存
  • (翻译)Entity Framework技巧系列之七 - Tip 26 – 28
  • (附源码)spring boot校园健康监测管理系统 毕业设计 151047
  • (南京观海微电子)——I3C协议介绍
  • (十五)使用Nexus创建Maven私服
  • (淘宝无限适配)手机端rem布局详解(转载非原创)
  • (五)MySQL的备份及恢复
  • (转)Unity3DUnity3D在android下调试
  • *++p:p先自+,然后*p,最终为3 ++*p:先*p,即arr[0]=1,然后再++,最终为2 *p++:值为arr[0],即1,该语句执行完毕后,p指向arr[1]
  • .bat批处理(七):PC端从手机内复制文件到本地
  • .net framework 4.8 开发windows系统服务