一、环境准备

在开始安装前，我们需要确保云服务器满足以下基本要求：

• 操作系统：推荐使用Linux发行版（如CentOS 7+或Ubuntu 18.04+）
• Java环境：Kafka需要Java 8或以上版本
• 服务器配置：至少2核CPU，4GB内存（生产环境建议更高配置）
• 存储空间：根据消息保留策略和数据量确定，建议SSD存储

二、安装Java环境

Kafka运行依赖Java环境，以下是安装OpenJDK的步骤：

# Ubuntu/Debian系统
sudo apt update
sudo apt install openjdk-11-jdk

# CentOS/RHEL系统
sudo yum install java-11-openjdk-devel

安装完成后验证Java版本：

java -version

三、下载并安装Kafka

从Apache官网下载最新稳定版Kafka：

wget https://downloads.apache.org/kafka/3.3.1/kafka_2.13-3.3.1.tgz
tar -xzf kafka_2.13-3.3.1.tgz
cd kafka_2.13-3.3.1

四、配置Kafka服务器

修改config/server.properties配置文件：

# 每个broker需要唯一的ID
broker.id=1

# 监听地址（改为云服务器内网IP）
listeners=PLAINTEXT://192.168.1.100:9092

# 日志存储目录（确保有足够空间）
log.dirs=/data/kafka-logs

# Zookeeper连接地址
zookeeper.connect=localhost:2181

五、启动Zookeeper和Kafka

Kafka依赖Zookeeper，先启动Zookeeper服务：

bin/zookeeper-server-start.sh config/zookeeper.properties &

然后启动Kafka服务：

bin/kafka-server-start.sh config/server.properties &

六、集群配置（可选）

对于生产环境，建议配置Kafka集群：

1. 为每台服务器分配唯一的broker.id
2. 在所有服务器的zookeeper.connect配置中添加所有Zookeeper节点
3. 确保服务器间网络互通

七、基本测试

创建测试主题：

bin/kafka-topics.sh --create --topic test --bootstrap-server localhost:9092 --partitions 1 --replication-factor 1

发送消息：

bin/kafka-console-producer.sh --topic test --bootstrap-server localhost:9092

接收消息：

bin/kafka-console-consumer.sh --topic test --bootstrap-server localhost:9092 --from-beginning

八、安全配置建议

• 配置SASL/SSL认证
• 设置ACL权限控制
• 启用日志压缩和加密
• 配置监控告警

九、性能优化建议

• 调整num.io.threads和num.network.threads参数
• 优化log.segment.bytes和log.retention.hours
• 合理设置partition数量
• 监控磁盘I/O和网络吞吐