加载中
【Kafka源码】Kafka代码模块

Kafka源码依赖于Scala环境,首先需要安装scala,这块请自行百度进行安装。 传送门 当然,我们要分析源码,需要下载源码,请自行从github上面下载。 说明:本文使用的kafka版本为0.10.0.1,这...

2017/10/23 11:19
10
【Kafka源码】Kafka启动过程

一般来说,我们是通过命令来启动kafka,但是命令的本质还是调用代码中的main方法,所以,我们重点看下启动类Kafka。源码下下来之后,我们也可以通过直接运行Kafka.scala中的main方法(需要指...

2017/10/23 17:23
17
【Kafka源码】日志处理

目前来说,kafka的日志中记录的内容比较多,具体的存储内容见这篇博客,写的比较好。可以看到,存储的内容还是比较多的,当存储文件比较大的时候,我们应该如何处理这些日志?下面我们通过k...

2017/11/06 21:13
10
【Kafka源码】ReplicaManager启动过程

在KafkaServer启动过程的入口中,会启动Replica Manager,众所周知,这是一个副本管理器。replica在Kafka中扮演的角色很重要,是保证消息不丢失的一个重要概念。 replica的个人理解概念如下:...

2017/11/08 11:27
11
【Kafka源码】SocketServer启动过程

SocketServer主要用于接收外部的网络请求,并把请求添加到请求队列中。 一、入口 在KafkaServer.scala中的start方法中,有这样的入口: socketServer = new SocketServer(config, metrics, k...

2017/11/07 14:18
11

没有更多内容

加载失败,请刷新页面

没有更多内容

返回顶部
顶部