2. Go语言环境搭建：Go SDK安装、GOPATH与Go Modules配置、常用IDE设置

在开始构建基于Kafka的分布式系统之前，必须搭建一个稳定、可复现的Go开发环境。本章将指导你完成Go SDK的安装、从传统GOPATH到现代Go Modules的迁移，以及VS Code与GoLand两款主流IDE的配置。一个正确的环境是后续所有代码示例和架构实验的基础。

2.1 Go SDK安装与版本选择

Go语言官方维护两个主要版本线：最新稳定版（如1.22.x）和旧版维护线（如1.21.x）。对于本课程涉及的Kafka客户端库（如Sarama、Confluent Kafka Go），建议使用Go 1.21及以上版本，以充分利用泛型、错误处理改进和模块兼容性。

2.2 GOPATH与Go Modules：从传统到现代

Go的依赖管理经历了两个时代：GOPATH模式（Go 1.11之前）和Go Modules模式（Go 1.11+，1.16起默认启用）。理解两者的区别，对于维护遗留项目和搭建新项目都至关重要。

2.2.1 初始化Go Modules项目

创建一个新的Kafka消费者组项目，并启用模块管理：

mkdir kafka-consumer-group
cd kafka-consumer-group
go mod init github.com/yourname/kafka-consumer-group

执行后生成 go.mod 文件，内容类似：

module github.com/yourname/kafka-consumer-group

go 1.22.2

2.2.2 GOPATH环境变量配置

即使使用Go Modules，GOPATH 仍然用于存放全局编译缓存和依赖缓存。建议统一配置：

# 在 ~/.bashrc 或 ~/.zshrc 中添加
export GOPATH=$HOME/go
export GOBIN=$GOPATH/bin
export PATH=$PATH:$GOBIN:/usr/local/go/bin

验证配置：

go env GOPATH
# 输出: /home/yourname/go

2.3 常用IDE设置：VS Code与GoLand

高效的IDE配置能显著提升Kafka消费者组开发中的调试效率。以下分别介绍两款主流IDE的关键设置。

2.3.1 VS Code 配置

安装官方Go扩展（golang.go）后，建议调整以下设置：

1. 自动保存 + 格式化： 在 settings.json 中启用 editor.formatOnSave 并设置为 gofumpt（更严格的格式化工具）。
2. 语言服务器： 使用 gopls（Go官方语言服务器），提供补全、跳转、重构和诊断。
3. 调试配置： 创建 .vscode/launch.json，支持断点调试Kafka消费者组。

// .vscode/settings.json 推荐配置
{
  "go.useLanguageServer": true,
  "go.formatTool": "gofumpt",
  "go.lintTool": "golangci-lint",
  "editor.formatOnSave": true,
  "[go]": {
    "editor.insertSpaces": true,
    "editor.tabSize": 4
  }
}

2.3.2 GoLand 配置

JetBrains GoLand 提供开箱即用的Go支持，但需注意以下优化：

2.4 环境验证：运行第一个Kafka消费者组示例

完成上述配置后，创建一个简单的Go程序验证环境是否正常：

// main.go
package main

import (
    "fmt"
    "os"
    "os/signal"
    "syscall"

    "github.com/IBM/sarama"
)

func main() {
    config := sarama.NewConfig()
    config.Consumer.Group.Rebalance.Strategy = sarama.BalanceStrategyRoundRobin

    consumerGroup, err := sarama.NewConsumerGroup(
        []string{"localhost:9092"},
        "my-consumer-group",
        config,
    )
    if err != nil {
        fmt.Printf("创建消费者组失败: %v\n", err)
        os.Exit(1)
    }
    defer consumerGroup.Close()

    fmt.Println("消费者组已连接，等待消息...")

    sig := make(chan os.Signal, 1)
    signal.Notify(sig, syscall.SIGINT, syscall.SIGTERM)
    <-sig
}

运行命令：

go mod tidy   # 自动下载 sarama 及其依赖
go run main.go

如果控制台输出 消费者组已连接，等待消息... 且无报错，说明Go环境、模块管理和IDE配置全部就绪。