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

我们会以 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 数据的原理的人

具体的目录结果如下:
在这里插入图片描述
链接:
Flink 消费 Kafka 中数据- 实战+源码解析Flink 消费 Kafka 中数据- 实战+源码解析

在这里插入图片描述
ps: 也欢迎多多提意见。

Logo

Kafka开源项目指南提供详尽教程,助开发者掌握其架构、配置和使用,实现高效数据流管理和实时处理。它高性能、可扩展,适合日志收集和实时数据处理,通过持久化保障数据安全,是企业大数据生态系统的核心。

更多推荐