您当前的位置: 首页 >  kafka

Flink 消费 Kafka 中数据- 实战+源码解析

蔚1 发布时间:2020-03-25 23:30:35 ,浏览量:5

对于实时计算来说,Flink 可以说是如日中天,国内很多公司也开始慢慢转向于 Flink 的使用。而对于 Flink 来说最常见的使用场景莫过于读取 Kafka 中的数据,若对此熟练掌握,在面试中拔得头筹也不是不可能的。

在本场 Chat 中,以 Flink 最新版本1.10为基础,会讲到如下内容:

  • 实战篇:
    • Flink 消费 Kafak的基本方式,比如如何从指定 offset 处消费记录
    • Flink 消费 Kafka 时如何获取相应的 offset、partition 等信息
    • 如何动态获取 Kafka topic 和 partition
  • 源码篇:
    • Flink 消费 Kafka 相关代码的整体继承体系
    • Flink 是如何保证一个分区被一个 task 消费
    • 像 setStartFromEarliest、setStartFromSpecificOffsets 等是如何起作用的
    • Flink 具体是如何消费 kafka 中数据的
    • Flink 消费 Kafka 如何保证 exactly once

适合人群: 想要了解 Flink 是如何读取 Kafka 数据的原理的人

阅读全文: http://gitbook.cn/gitchat/activity/5e6f2d4a71896862179bffd6

您还可以下载 CSDN 旗下精品原创内容社区 GitChat App ,阅读更多 GitChat 专享技术内容哦。

FtooAtPSkEJwnW-9xkCLqSTRpBKX

关注
打赏
1688896170
查看更多评论

蔚1

暂无认证

  • 5浏览

    0关注

    4645博文

    0收益

  • 0浏览

    0点赞

    0打赏

    0留言

私信
关注
热门博文
立即登录/注册

微信扫码登录

0.0483s