免积分下载：http://download.csdn.net/detail/wl044090432/9487835
目录内容：
Kafka源码解析
目录
3.6.2.1 LeaderAndISRCommand处理流程… 24
3.6.2.2 StopReplicaCommand处理流程… 27
3.6.2.3 maybeShrinkIsr处理流程… 28
3.6.4.1 RequestKeys.ProduceKey. 32
3.6.4.2 RequestKeys. FetchKey. 34
3.6.4.3 RequestKeys. OffsetsKey. 34
3.6.4.4 RequestKeys. MetadataKey. 35
3.6.4.5 RequestKeys. LeaderAndIsrKey. 36
3.6.4.6 RequestKeys. StopReplicaKey. 36
3.6.4.7 RequestKeys. UpdateMetadataKey. 36
3.6.4.8 RequestKeys. ControlledShutdownKey. 37
3.6.4.9 RequestKeys. OffsetCommitKey. 37
3.6.4.10 RequestKeys. OffsetFetchKey. 38
3.6.4.11 RequestKeys. ConsumerMetadataKey. 38
3.7.1 KafkaController成为leader的过程… 39
3.7.2 kafkaController的初始化（leader）… 41
3.7.3 KafkaController PartitionStateMachine. 43
3.7.4 KafkaController PartitionLeaderSelector. 45
3.7.4.1 NoOpLeaderSelector. 45
3.7.4.2 OfflinePartitionLeaderSelector. 46
3.7.4.3 ReassignedPartitionLeaderSelector. 46
3.7.4.4 PreferredReplicaPartitionLeaderSelector. 47
3.7.4.5 ControlledShutdownLeaderSelector. 47
3.7.5 KafkaController ReplicaStateMachine. 48
3.7.6 KafkaController内部的listener. 51
3.7.6.1 brokerChangeListener. 51
3.7.6.2 topicChangeListener. 52
3.7.6.3 deleteTopicsListener. 53
3.7.6.4 preferredReplicaElectionListener. 53
3.7.6.5 partitionReassignedListener. 54
3.7.6.6 AddPartitionsListener. 57
3.7.7 KafkaController内部rebalance流程… 57
3.7.8 KafkaController内部topic删除流程TopicDeletionManager. 59
3.7.9 KafkaController(leader)和其它broker通信流程ControllerChannelManager. 60
原创文章，作者：Maggie-Hunter，如若转载，请注明出处：https://blog.ytso.com/11808.html