258分钟
大数据实时消息存储系统:Kafka
这个课程适合对大数据处理、实时消息系统感兴趣的学员。通过这个课程,你不仅可以学习到Kafka的理论知识,也可以通过实践操作,掌握Kafka的使用方法。
这个课程适合对大数据处理、实时消息系统感兴趣的学员。通过这个课程,你不仅可以学习到Kafka的理论知识,也可以通过实践操作,掌握Kafka的使用方法。
0.课程介绍
1.1 消息系统基础(1)
1.2 消息系统的分类(2)
2.1 Kafka 的体系架构
2.2 主题、分区与副本
2.3 Kafka的生产者
2.4 Kafka的消费者
3.1 安装部署 Kafka
3.2 部署Kafka单机多Broker模式(1)
3.3 部署Kafka单机多Broker模式(2)
3.4 使用命令行工具测试Kafka
3.5 Kafka配置参数详解
3.6 Kafka在ZooKeeper中存储的元数据
4.1 Kafka 应用程序开发
4.2 开发Scala版本的客户端程序
4.3 发布与订阅自定义消息
5.1 Kafka 核心原理解析
5.2 消息的传输保障
5.3 Leader的选举
5.4 Kafka的日志清理
6.1 Kafka 与外部系统的集成
6.2 基于Spark Streaming接收器方式集成Kafka
6.3 基于Spark Streaming直接读取方式
6.4 将Kafka作为Flink的Source Connector
6.5 将Kafka作为Flink的Sink Connector
课后测试
赵渝强
曾任京东大学大数据学院院长
曾任Oracle中国有限公司高级技术顾问