1. CentOS7环境下Kafka安装方案选型

在CentOS7上部署Kafka主要有两种主流方案：原生安装和容器化部署。原生安装适合需要长期稳定运行的生产环境，能直接调用系统资源；容器化方案则更适合开发测试环境，具备快速部署和隔离优势。根据实际运维经验，内存小于8GB的机器建议选择原生安装，避免Docker带来的额外开销。

关键决策点：生产环境优先选择yum安装的Confluent平台（包含完整工具链），开发环境可考虑Docker快速部署。Confluent提供的OSS版本已包含Schema Registry等企业级组件。

2. 原生安装详细步骤与避坑指南

2.1 前置环境准备

首先确保系统已安装Java 8+：

sudo yum install java-1.8.0-openjdk-devel java -version # 验证版本

常见问题：

• 若遇到No package java-1.8.0-openjdk-devel available，需先配置EPEL仓库：

  sudo yum install epel-release sudo yum update

2.2 配置Confluent官方源

导入GPG密钥并创建repo文件：

sudo rpm --import https://packages.confluent.io/rpm/7.0/archive.key sudo tee /etc/yum.repos.d/confluent.repo <<EOF [Confluent] name=Confluent repository baseurl=https://packages.confluent.io/rpm/7.0 gpgcheck=1 gpgkey=https://packages.confluent.io/rpm/7.0/archive.key enabled=1 EOF

重要提示：baseurl中的7.0表示Confluent平台主版本号，需根据实际需求调整。最新版可查阅 Confluent官方文档

2.3 安装核心组件

执行完整安装（包含Zookeeper、Kafka、Schema Registry等）：

sudo yum clean all sudo yum install confluent-platform

验证安装：

rpm -qa | grep confluent # 应看到kafka/schema-registry等包

2.4 服务启动与验证

启动所有服务：

sudo systemctl start confluent-zookeeper sudo systemctl start confluent-kafka

检查状态：

sudo systemctl status confluent-kafka # 正常应显示"active (running)"

端口开放建议：

sudo firewall-cmd --permanent --add-port=9092/tcp # Kafka sudo firewall-cmd --permanent --add-port=2181/tcp # Zookeeper sudo firewall-cmd --reload

3. Docker容器化部署方案

3.1 安装Docker环境

sudo yum install -y yum-utils sudo yum-config-manager --add-repo https://download.docker.com/linux/centos/docker-ce.repo sudo yum install docker-ce docker-ce-cli containerd.io sudo systemctl start docker

3.2 使用官方Compose文件

创建docker-compose.yml：

version: '3' services: zookeeper: image: confluentinc/cp-zookeeper:7.0.1 ports: - "2181:2181" environment: ZOOKEEPER_CLIENT_PORT: 2181 kafka: image: confluentinc/cp-kafka:7.0.1 depends_on: - zookeeper ports: - "9092:9092" environment: KAFKA_ZOOKEEPER_CONNECT: "zookeeper:2181" KAFKA_ADVERTISED_LISTENERS: "PLAINTEXT://kafka:9092" KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1

启动集群：

docker-compose up -d

3.3 容器特有配置技巧

1. 数据持久化：在kafka服务中添加volumes

   volumes: - ./kafka-data:/var/lib/kafka/data

2. 调整JVM参数：

   environment: KAFKA_HEAP_OPTS: "-Xmx2G -Xms2G"

3. 监控配置：

   docker stats kafka zookeeper

4. 生产环境调优指南

4.1 关键参数配置

编辑/etc/kafka/server.properties：

# 推荐配置 num.network.threads=8 num.io.threads=16 socket.send.buffer.bytes=102400 socket.receive.buffer.bytes=102400 log.retention.hours=168 # 保留7天 num.partitions=8 # 默认分区数

4.2 系统级优化

1. 文件描述符限制：

   echo "* soft nofile 128000" >> /etc/security/limits.conf echo "* hard nofile 128000" >> /etc/security/limits.conf

2. 交换空间调整：

   sudo sysctl vm.swappiness=1

3. 磁盘调度策略（SSD建议）：

   echo 'deadline' > /sys/block/sda/queue/scheduler

4.3 监控方案

推荐搭配Prometheus+Grafana：

# 安装JMX exporter wget https://repo1.maven.org/maven2/io/prometheus/jmx/jmx_prometheus_javaagent/0.16.1/jmx_prometheus_javaagent-0.16.1.jar

配置kafka-jmx.yml：

startDelaySeconds: 0 ssl: false lowercaseOutputName: false rules: - pattern: "kafka.server<type=(.+), name=(.+)><>(Count|Value|Mean|StdDev|OneMinuteRate|FiveMinuteRate|FifteenMinuteRate|Percentile\d*)" name: "kafka_server_$1_$2_$3"

5. 常见问题排查手册

5.1 启动失败排查

现象：Kafka无法启动，日志显示java.lang.OutOfMemoryError

解决方案：

1. 调整JVM内存：

   sudo vi /etc/kafka/kafka-env.conf export KAFKA_HEAP_OPTS="-Xmx4G -Xms4G"

2. 检查系统内存：

   free -h # 确保可用内存大于配置值

5.2 生产者连接问题

现象：Producer报错Connection to node -1 could not be established

排查步骤：

1. 验证监听地址：

   netstat -tulnp | grep 9092

2. 检查广告地址：

   # server.properties中需配置 advertised.listeners=PLAINTEXT://your_server_ip:9092

5.3 磁盘I/O瓶颈

优化方案：

1. 使用多磁盘目录：

   log.dirs=/data1/kafka,/data2/kafka

2. 监控磁盘写入：

   iostat -x 1 # 关注%util和await指标

6. 安全加固建议

6.1 基础防护

1. 禁用PLAINTEXT协议：

   listeners=SASL_SSL://:9093 security.inter.broker.protocol=SASL_SSL

2. 启用ACL：

   kafka-acls --authorizer-properties zookeeper.connect=localhost:2181 \ --add --allow-principal User:Producer --operation WRITE --topic test

6.2 认证配置

1. 创建JAAS文件：

   KafkaServer { org.apache.kafka.common.security.plain.PlainLoginModule required username="admin" password="admin-secret" user_admin="admin-secret"; };

2. 配置server.properties：

   sasl.enabled.mechanisms=PLAIN sasl.mechanism.inter.broker.protocol=PLAIN

7. 性能测试方法

7.1 基准测试工具

使用kafka-producer-perf-test：

kafka-producer-perf-test \ --topic benchmark \ --num-records 1000000 \ --record-size 1024 \ --throughput -1 \ --producer-props bootstrap.servers=localhost:9092

关键指标解读：

• 吞吐量（MB/sec）：单broker通常可达50-100MB/s
• 延迟（ms）：99%的请求应<10ms

7.2 集群扩展建议

当出现以下情况时应考虑扩容：

• 磁盘使用率持续>70%
• CPU负载长期>60%
• 网络吞吐接近带宽上限

扩容步骤：

1. 横向增加broker节点
2. 重新分配分区：

   kafka-reassign-partitions --execute \ --reassignment-json-file reassign.json \ --bootstrap-server localhost:9092

8. 运维管理技巧

8.1 日志清理策略

1. 基于大小清理：

   log.retention.bytes=1073741824 # 1GB

2. 定时压缩：

   kafka-log-dirs --describe --bootstrap-server localhost:9092

8.2 版本升级步骤

1. 滚动升级顺序： Zookeeper → Kafka brokers → Clients

2. 兼容性检查：

   kafka-broker-api-versions --bootstrap-server localhost:9092

8.3 备份恢复方案

1. 元数据备份：

   zookeeper-shell localhost:2181 get /brokers/ids

2. 数据备份：

   rsync -avz /var/lib/kafka/data backup-server:/kafka-backup