# 克隆源码仓库
git clone https://github.com/apache/kafka.git

# 进入目录
cd kafka

# 编译
./gradlew clean build -x test

3.5 Docker 镜像

使用 Docker 运行 Kafka：

# 拉取官方镜像
docker pull bitnami/kafka

# 运行容器（需要先运行 ZooKeeper）
docker run -d --name zookeeper -p 2181:2181 bitnami/zookeeper
docker run -d --name kafka -p 9092:9092 --link zookeeper:zookeeper bitnami/kafka

4. 验证步骤

下载完成后，建议验证文件完整性：

# 计算MD5哈希值
md5sum kafka_2.13-3.5.1.tgz

# 计算SHA256哈希值
sha256sum kafka_2.13-3.5.1.tgz

# 与官方提供的哈希值进行比对

5. 安装准备

5.1 系统要求

• 操作系统：Linux (推荐)、Windows、macOS
• Java：JDK 8 或更高版本
• 内存：至少 4GB RAM，生产环境建议 16GB+
• 存储：根据数据量需求，建议使用 SSD 或 HDD 阵列
• 网络：局域网环境，建议 1Gbps 以上带宽
• 依赖：ZooKeeper 3.4.6 或更高版本

5.2 环境配置

# 设置Java环境变量
export JAVA_HOME=/path/to/java

# 设置Kafka环境变量
export KAFKA_HOME=/path/to/kafka
export PATH=$PATH:$KAFKA_HOME/bin

# 配置server.properties
# 在$KAFKA_HOME/config/server.properties中添加配置
# 基本配置
broker.id=0
listeners=PLAINTEXT://:9092
log.dirs=/path/to/kafka-logs
zookeeper.connect=localhost:2181

# 高级配置
num.partitions=1
default.replication.factor=1
min.insync.replicas=1

6. 生产环境推荐

6.1 硬件配置

• Broker节点：8-16核CPU，32-64GB RAM，2TB+ SSD
• 建议至少部署 3 个节点以实现高可用

6.2 集群规划

• 小型集群：3个节点
• 中型集群：5-10个节点
• 大型集群：10+节点

6.3 存储配置

• 使用 RAID 10 配置提高数据可靠性
• 为日志目录配置独立的磁盘
• 考虑使用 SSD 存储以提高性能

6.4 高可用性

• 部署多个 Broker 节点
• 设置合理的副本因子（通常为 3）
• 配置 ZooKeeper 集群高可用

6.5 监控与维护

• 使用 Kafka Manager 或 Confluent Control Center 进行集群管理
• 配置 Prometheus + Grafana 监控
• 定期清理过期日志
• 设置合理的日志保留策略

6.6 安全配置

• 启用 Kerberos 认证
• 配置 SSL 加密传输
• 设置访问控制列表 (ACL)
• 定期更新密码和密钥

7. 常见问题

• 问题：启动 Kafka 时出现 Java 版本错误
  解决方案：确保安装了正确版本的 JDK，并设置了正确的 JAVA_HOME 环境变量
• 问题：Kafka 无法连接到 ZooKeeper
  解决方案：确保 ZooKeeper 服务正常运行，检查连接配置
• 问题：Kafka 生产或消费速度慢
  解决方案：优化 Kafka 配置参数，如 batch.size、linger.ms 等