Kafka源码剖析

# 4.1 Kafka源码剖析之源码阅读环境搭建

首先下载源码：http://archive.apache.org/dist/kafka/1.0.2/kafka-1.0.2-src.tgz

gradle-4.8.1下载地址：https://services.gradle.org/distributions/gradle-4.8.1-bin.zip

Scala-2.12.12下载地址：https://downloads.lightbend.com/scala/2.12.12/scala-2.12.12.msi

# 4.1.1 安装配置Gradle

解压gradle4.8.-bin.zip到一个目录

配置环境变量，其中GRADLE_HOME指向gradle解压到的根目录，GRADLE_USER_HOME指向gradle的本地仓库位置。

Kafka_Page230_001

PATH环境变量：

Kafka_Page231_001

进入GRADLE_USER_HOME目录，添加init.gradle，配置gradle的源：

init.gradle内容：

allprojects
{
    repositories
    {
        maven
        {
            url 'https://maven.aliyun.com/repository/public/'
        }
        maven
        {
            url 'https://maven.aliyun.com/nexus/content/repositories/google'
        }
        maven
        {
            url 'https://maven.aliyun.com/nexus/content/groups/public/'
        }
        maven
        {
            url 'https://maven.aliyun.com/nexus/content/repositories/jcenter'
        }
        all
        {
            ArtifactRepository repo - >
                if(repo instanceof MavenArtifactRepository)
                {
                    def url = repo.url.toString()
                    if(url.startsWith('https://repo.maven.apache.org/maven2/') || url.startsWith('https://repo.maven.org/maven2') || url.startsWith('https://repo1.maven.org/maven2') || url.startsWith('https://jcenter.bintray.com/'))
                    {
                        //project.logger.lifecycle "Repository ${repo.url} replaced by $REPOSITORY_URL."
                        remove repo
                    }
                }
        }
    }
    buildscript
    {
        repositories
        {
            maven
            {
                url 'https://maven.aliyun.com/repository/public/'
            }
            maven
            {
                url 'https://maven.aliyun.com/nexus/content/repositories/google'
            }
            maven
            {
                url 'https://maven.aliyun.com/nexus/content/groups/public/'
            }
            maven
            {
                url 'https://maven.aliyun.com/nexus/content/repositories/jcenter'
            }
            all
            {
                ArtifactRepository repo - >
                    if(repo instanceof MavenArtifactRepository)
                    {
                        def url = repo.url.toString()
                        if(url.startsWith('https://repo1.maven.org/maven2') || url.startsWith('https://jcenter.bintray.com/'))
                        {
                            //project.logger.lifecycle "Repository ${repo.url} replaced by $REPOSITORY_URL."
                            remove repo
                        }
                    }
            }
        }
    }
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70

保存并退出，打开cmd，运行：

设置成功。