课时01

mq技术选型和对比

课时02

AKF详解

课时03

kafka名词介绍及整合zookeeper

课时04

kafka的broker和partition介绍

课时05

幂等重复消费

课时06

kafka与磁盘和网卡的技术点

课时07

课前概述

课时08

kafka的安装和使用

课时09

分区概念

课时10

consumer选择单线程和多线程对比

课时11

课堂答疑

课时12

kafka生产者api演示

课时13

kafka消费者api演示

课时14

持久化操作

课时15

多线程下手动提交offset方式

课时16

同步

课时17

单机

课时18

时间戳

课时19

性能

课时20

分区可靠性和一致性

课时21

ack为-1时

课时22

ack为1时(1)

课时23

ack为1时(2)

课时24

redis

课时25

KAFKA

课时26

课堂概述

课时27

索引

课时28

消费者数据可靠性

课时29

时间戳之自定义消费数据

课时30

生产者的基本架构

课时31

阻塞和非阻塞

课时32

producer的参数调整

课时33

源码剖析

课时34

io前置知识介绍

课时35

poll的maybeUpdate、select、handler

课时36

服务端接受和管理连接

课时37

完成请求和响应的正确匹配

课时38

课前概述

课时39

外界如何通信和内部数据写磁盘

课时40

旧知识回顾和课堂答疑

课时41

生产者在socket中如何保证顺序

课时42

课堂答疑

课时43

为什么要有这么多中间件

课时44

前置知识

课时45

shouldRoll介绍

课时46

log、offset、timeIndex

课时47

fileRecords和offsetIndex

课时48

Replica

课时49

回顾知识点

课时50

replicaManger(1)

课时51

replicaManger(2)

课时52

replicaManger(3)

课时53

replicaManger(4)

课时54

答疑(1)

课时55

答疑(2)

课时56

appendToLocalLog

课时57

replica同步机制

课时58

replica同步机制

课时59

答疑

课时60

总结

课时61

replicaManger中ACK等于-1时

课时62

replicafetcherManager(1)

课时63

replicafetcherManager(2)

课时64

Leader处理fetch

课时65

Leader返回结果

课时66

partitionStates

课时67

总结

课时68

答疑

课时69

Controller

课时70

initZkClient(time)

课时71

KafkaController

课时72

select

课时73

MetadataCache和MetadataSnapshot和updateMetadata

课时74

initializeControllerContext

课时75

ControllerChannelManager

课时76

MetadataSnapshot

课时77

创建topics和参数讲解

课时78

cli-client

课时79

AdminZkClient

课时80

assigReplicasToBrokers方法讲解(1)

课时81

assigReplicasToBrokers方法讲解(2)

课时82

assigReplicasToBrokers方法讲解(23

课时83

assigReplicasToBrokers方法讲解(4)

课时84

assigReplicasToBrokers方法讲解(5)

课时85

作业和问答(1)

课时86

作业和问答（2）

课时87

讲解小作业

课时88

讲解CREATE_TOPICS方法

课时89

select方法讲解

课时90

process方法讲解

课时91

onNewPartitionCreation方法讲解1

课时92

handleStateChanges方法讲解1

课时93

partitionStateMachine方法讲解

课时94

ControllerBrokerRequestBatch方法讲解

课时95

onNewPartitionCreation方法讲解2

课时96

initializeLeaderAndIsrForPartitions方法讲解

课时97

sendRequestToBrokers方法讲解

课时98

KafkaApis讲解

课时99

handl eTopicMetadataRequest方法讲解

课时100

答疑1

课时101

handleLeaderAndIsrRequest方法讲解

课时102

becomeLeaderOrFollower方法讲解

课时103

总结

课时104

答疑2

课时105

consumer

课时106

Scalable

课时107

问题：分布式 治理或协调

课时108

kafkaconsumer

课时109

NetworkClient

课时110

poll方法

课时111

acquireAndEnsureOpen方法

课时112

poll方法中do循环

课时113

ConsumerCoordinator类中的poll方法

课时114

sendFindCoordinatorRequest方法

课时115

FIND_COORDINATOR调用handleFindCoordinatorRequest方法

课时116

答疑1

课时117

FindCoordinatorResponseHandler

课时118

joingroup

课时119

groupadd及LEADER的Assignment

课时120

Stable

课时121

答疑2

课时122

Stable

课时123

答疑3

课时124

updateFetchPositions方法讲解

课时125

updateFetchPositions方法分析

课时126

pollForFetches方法讲解

课时127

fetchablePartitions方法讲解

课时128

fetcher类讲解

课时129

kafka消息机制

课时130

handleCompletedReceives

课时131

答疑1

课时132

submit offset持久化

课时133

handleLeaderAndIsrRequest(1)

课时134

handleLeaderAndIsrRequest(2)

课时135

答疑2

课时136

kafka事务

课时137

生产者

课时138

消息信息传递的等级

课时139

多条消息发送事务是什么样的

课时140

答疑（1）

课时141

课后作业及讲解写作业方法

课时142

答疑（2）

课时143

kafka connect

课时144

source和sink

课时145

platform框架

课时146

kafka中的角色

课时147

演示实例

课时148

如何基于他的api开发一个connect和他的platform是怎么运行的

课时149

FileStreamSoutceConnetor类

课时150

FileStreamSoutceTask类

课时151

ConnectStandalone类

课时152

worker类

课时153

workersourcetask类

课时154

答疑（1）

课时155

kafka connect的好处

课时156

总结

课时157

答疑（2）

课时158

kafka总结

课时159

kafka框架模型

课时160

ack生产过程

课时161

事务

课时162

消费进度和分配规则

课时163

kafka灵活性

课时164

处理过程

课时165

第一阶段的同一组4个consumer不能自动提交offset

课时166

多分区处理

课时167

答疑（1）

课时168

本课总结

课时169

答疑（2）