未记录事实核验 · 状态：维护中

记录仅说明核验时间与维护状态，不保证适用于所有环境；使用前请留意正文中的版本、适用条件与风险提示。

Kafka环境安装与配置 - 搭建你的第一个Kafka集群

🔧 新人的第一个"滑铁卢"

以下是假设的教学情境：新入职的运维工程师小张接到第一个任务："搭建Kafka集群，明天上线。" 小张心想："不就是安装个软件吗？" 第一次尝试时，他直接下载压缩包并简单启动，结果日志里满是ERROR信息。第二次尝试发现需要先启动Zookeeper，但又遇到端口冲突问题。第三次虽然启动成功，但生产者和消费者都无法连接。第四次配置了advertised.listeners，本地测试通过，但其他机器仍然无法访问。一天过去了，Kafka还没跑起来。

这就是Kafka安装的现实——看起来简单，实际上处处都是坑。掌握正确的安装配置方法，能让你在新环境中快速建立技术信誉。

🔧 环境准备

💻 硬件要求

Kafka作为分布式消息系统，对硬件资源有一定的要求。CPU方面，虽然最低2核就能运行，但推荐4核以上，因为Kafka是CPU密集型应用，需要处理大量的消息序列化、网络通信和磁盘IO操作。内存配置至关重要，最少需要4GB，推荐8GB以上，其中JVM堆内存通常占用1-2GB，剩余内存用于系统页缓存，这对Kafka的性能至关重要。存储方面，虽然20GB能满足基本需求，但生产环境建议使用50GB以上的SSD，因为Kafka的性能很大程度上取决于磁盘IO能力。网络带宽也不容忽视，集群间需要频繁通信，最低100Mbps，生产环境推荐1Gbps。

组件	最低配置	推荐配置	说明
CPU	2核	4核以上	Kafka是CPU密集型应用
内存	4GB	8GB以上	JVM + 系统缓存
硬盘	20GB	50GB SSD	日志存储需要较快IO
网络	100Mbps	1Gbps	集群间通信频繁

📋 软件要求

Kafka基于Java开发，因此Java运行环境是必须的。推荐使用Java 8或更高版本，可以通过java -version命令检查当前版本。操作系统支持方面，Linux是首选平台，推荐CentOS 7+或Ubuntu 16.04+，这些版本经过充分验证且稳定性较好。macOS用户需要10.12或更高版本，Windows用户建议使用Windows 10并启用WSL子系统来获得更好的兼容性。

# 1. Java 8 或以上版本
java -version
# java version "1.8.0_XXX" 或更高

# 2. 操作系统支持
Linux (推荐)：CentOS 7+, Ubuntu 16.04+
macOS：10.12+
Windows：10+ (需要WSL)

可选软件能大幅提升开发和运维体验。Docker可以实现容器化部署，简化环境管理和集群搭建过程。Kafka Manager提供Web界面来监控集群状态、管理Topic和查看消费者组信息。Kafka Tool作为图形化客户端，能够可视化查看Topic数据、分区分布和消费者偏移量，对调试和学习非常有帮助。

📦 下载Kafka

🌐 官方下载

从Apache Kafka官网下载是最安全可靠的方式。访问https://kafka.apache.org/downloads了解发行信息；本文命令以Kafka 2.8.1的ZooKeeper模式为练习基线，不应直接套用于任意最新稳定版本或所有2.8.0以上版本。特别注意要下载Binary版本而不是Source版本，Binary版本已经编译完成可以直接运行，而Source版本需要自己编译。

版本号命名规则需要理解：以kafka_2.13-2.8.1.tgz为例，2.13表示Scala版本，2.8.1表示Kafka版本。选择Scala版本时，建议选择与你的开发环境匹配的版本，如果没有特殊需求，选择最新的Scala版本即可。

# Linux/macOS
wget https://downloads.apache.org/kafka/2.8.1/kafka_2.13-2.8.1.tgz

# 或使用curl
curl -O https://downloads.apache.org/kafka/2.8.1/kafka_2.13-2.8.1.tgz

# 版本说明：
# kafka_2.13-2.8.1.tgz
#        ↑      ↑
#    Scala版本 Kafka版本

下载完成后务必验证文件完整性，避免因下载中断或网络问题导致的文件损坏。使用sha512sum命令计算文件哈希值，然后与官网提供的checksum值进行对比，确保两者完全一致。

# 检查文件完整性
sha512sum kafka_2.13-2.8.1.tgz

# 对比官网提供的checksum值

🐳 Docker方式（可选）

Docker方式适合快速搭建测试环境或学习使用。通过docker-compose可以一键启动包含Zookeeper和Kafka的完整环境。这种方式的优势是环境隔离、配置简单、易于清理，特别适合初学者快速上手。

# docker-compose.yml
version: '3.8'
services:
  zookeeper:
    image: confluentinc/cp-zookeeper:latest
    environment:
      ZOOKEEPER_CLIENT_PORT: 2181
      ZOOKEEPER_TICK_TIME: 2000
    ports:
      - "2181:2181"

  kafka:
    image: confluentinc/cp-kafka:latest
    depends_on:
      - zookeeper
    ports:
      - "9092:9092"
    environment:
      KAFKA_BROKER_ID: 1
      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
      KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://localhost:9092
      KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1

🗂️ 解压和目录结构

📁 解压安装包

解压过程需要注意目录选择和权限设置。将Kafka安装到/opt目录是Linux系统的标准做法，这个目录专门用于可选的软件包。创建软链接的好处是便于版本管理，当需要升级Kafka版本时，只需要更新软链接指向即可，不会影响现有的脚本和配置。

# 解压到指定目录
tar -xzf kafka_2.13-2.8.1.tgz

# 移动到合适位置
sudo mkdir -p /opt/kafka
sudo mv kafka_2.13-2.8.1 /opt/kafka/

# 创建软链接（便于版本管理）
sudo ln -s /opt/kafka/kafka_2.13-2.8.1 /opt/kafka/current

# 设置所有者
sudo chown -R $USER:$USER /opt/kafka

🗃️ 目录结构解析

理解Kafka的目录结构对后续的配置和运维至关重要。bin目录包含所有可执行脚本，其中kafka-server-start.sh和kafka-server-stop.sh用于启动停止Kafka服务，kafka-topics.sh用于Topic管理，kafka-console-producer.sh和kafka-console-consumer.sh提供命令行的生产消费工具，zookeeper-server-start.sh用于启动内置的ZooKeeper服务。config目录存储所有配置文件，server.properties是Kafka的主配置文件，包含broker设置、网络配置、存储路径等关键参数。libs目录包含所有JAR依赖库，一般不需要修改。logs目录在首次运行后自动生成，包含所有运行日志。site-docs目录包含离线文档，便于在无网络环境下查阅。

目录/文件	说明
bin/	可执行脚本目录
bin/kafka-server-start.sh	启动Kafka服务
bin/kafka-server-stop.sh	停止Kafka服务
bin/kafka-topics.sh	Topic管理
bin/kafka-console-producer.sh	控制台生产者
bin/kafka-console-consumer.sh	控制台消费者
bin/zookeeper-server-start.sh	启动ZooKeeper
config/	配置文件目录
config/server.properties	Kafka主配置
config/zookeeper.properties	ZooKeeper配置
config/producer.properties	生产者配置
config/consumer.properties	消费者配置
libs/	JAR依赖库
logs/	日志文件（运行后生成）
site-docs/	文档

🔧 ZooKeeper配置

📝 配置文件修改

ZooKeeper是Kafka集群的协调服务，负责维护集群元数据、领导者选举、配置管理等核心功能。在Kafka 2.8.0之前的版本中，ZooKeeper是必需的依赖。本文以Kafka 2.8.1的ZooKeeper模式为练习范围，不据此判断生产环境中各部署模式的使用占比；采用KRaft模式时不能直接照用下文ZooKeeper配置。

ZooKeeper的核心配置相对简单但每个参数都很重要。dataDir指定数据存储路径，建议选择性能较好的磁盘并确保有足够空间。clientPort是客户端连接端口，默认2181，如果有端口冲突需要修改。maxClientCnxns控制单个IP的最大连接数，设置为0表示不限制，生产环境建议根据实际需求设置合理值。

# 编辑ZooKeeper配置
vim /opt/kafka/current/config/zookeeper.properties

# ZooKeeper基础配置
dataDir=/opt/kafka/data/zookeeper
clientPort=2181
maxClientCnxns=0

# 性能优化配置
tickTime=2000
initLimit=10
syncLimit=5

# 集群配置（单机可省略）
# server.1=localhost:2888:3888
# server.2=localhost:2889:3889
# server.3=localhost:2890:3890

性能相关的配置参数需要根据集群规模调整。tickTime是ZooKeeper的基础时间单位（毫秒），影响心跳检测和会话超时的精度。initLimit定义follower初始化连接到leader的最大时间，单位是tickTime的倍数。syncLimit定义follower同步到leader的最大时间。集群模式下需要配置每个节点的server.id，格式为server.id=host:port1:port2，其中port1用于follower连接leader，port2用于leader选举。

创建数据目录时要注意权限设置，确保Kafka进程有读写权限。目录路径选择要考虑磁盘空间和性能，避免与系统盘共享磁盘IO资源。

# 创建数据目录
mkdir -p /opt/kafka/data/zookeeper

# 设置权限
chmod 755 /opt/kafka/data/zookeeper

🚀 启动ZooKeeper

ZooKeeper必须在Kafka之前启动。前台运行方式便于观察启动日志和排查问题，后台运行方式适合正式环境。使用nohup命令确保进程在SSH断开后继续运行，重定向日志到文件便于后续排查问题。

# 启动ZooKeeper（前台运行）
/opt/kafka/current/bin/zookeeper-server-start.sh \
    /opt/kafka/current/config/zookeeper.properties

# 后台运行前先创建日志目录
mkdir -p /opt/kafka/logs
nohup /opt/kafka/current/bin/zookeeper-server-start.sh \
    /opt/kafka/current/config/zookeeper.properties > \
    /opt/kafka/logs/zookeeper.log 2>&1 &

# 验证启动
netstat -tlnp | grep 2181
# 应该看到端口2181被监听

启动验证很重要，通过netstat命令检查端口监听状态，确保2181端口处于LISTEN状态。如果端口没有监听，检查zookeeper.log文件中的错误信息，常见问题包括端口冲突、权限不足、磁盘空间不够等。

⚙️ Kafka配置

📋 核心配置文件

Kafka的配置文件server.properties包含大量参数，但核心参数相对有限。理解这些关键配置对成功运行Kafka集群至关重要。配置修改时建议先备份原文件，避免配置错误导致无法回滚。

# 编辑Kafka主配置
vim /opt/kafka/current/config/server.properties

🔧 基础配置

Kafka的基础配置决定了broker的身份、网络访问方式和数据存储位置。broker.id是集群中每个broker的唯一标识，必须是非负整数且在集群中唯一。listeners定义broker监听的网络接口和端口，PLAINTEXT表示无加密通信。advertised.listeners是客户端用来连接broker的地址，这个参数经常是连接问题的根源，必须是客户端能够访问的地址。

网络相关配置影响Kafka的并发处理能力。num.network.threads控制处理网络请求的线程数，通常设置为CPU核数。num.io.threads控制处理IO请求的线程数，包括磁盘读写，建议设置为CPU核数的2倍。socket缓冲区大小影响网络性能，需要根据网络环境和消息大小调整。

############################# 服务器基础配置 #############################
# Broker ID（集群中每个broker必须唯一）
broker.id=0

# 监听端口配置
listeners=PLAINTEXT://localhost:9092
advertised.listeners=PLAINTEXT://localhost:9092

# 日志目录配置
log.dirs=/opt/kafka/data/kafka-logs

# 分区副本配置
num.network.threads=3
num.io.threads=8
socket.send.buffer.bytes=102400
socket.receive.buffer.bytes=102400
socket.request.max.bytes=104857600

############################# 日志配置 #############################
# 默认分区数
num.partitions=1

# 日志保留小时数
log.retention.hours=168

# 日志分段大小
log.segment.bytes=1073741824

# 日志保留检查间隔
log.retention.check.interval.ms=300000

############################# ZooKeeper配置 #############################
# ZooKeeper连接配置
zookeeper.connect=localhost:2181
zookeeper.connection.timeout.ms=18000

############################# 群组协调器配置 #############################
# 群组协调器配置
group.initial.rebalance.delay.ms=0

日志配置直接影响数据保留和磁盘使用。num.partitions设置新Topic的默认分区数，分区数影响并发度和性能。log.retention.hours控制消息保留时间，168小时即7天，需要根据业务需求和磁盘容量平衡。log.segment.bytes定义日志分段大小，当日志文件达到这个大小时会创建新的分段文件。较大的分段减少文件数量但增加内存使用，较小的分段便于清理过期数据但增加文件管理开销。

🏗️ 创建数据目录

数据目录的创建和权限设置直接影响Kafka的正常运行。目录路径建议选择专门的数据磁盘，避免与系统盘竞争IO资源。如果有多块磁盘，可以配置多个日志目录，Kafka会自动在这些目录间分布数据。

# 创建Kafka数据目录
mkdir -p /opt/kafka/data/kafka-logs

# 创建日志目录
mkdir -p /opt/kafka/logs

# 设置权限
chmod -R 755 /opt/kafka/data

权限设置要确保Kafka进程用户有读写权限。生产环境建议创建专门的kafka用户运行服务，避免使用root用户带来的安全风险。

🚀 启动Kafka

启动Kafka前必须确保ZooKeeper已经运行并可访问。启动命令需要指定配置文件路径，建议使用绝对路径避免路径问题。后台运行时使用nohup和重定向确保进程稳定运行和日志记录。

# 启动Kafka服务（确保ZooKeeper已启动）
/opt/kafka/current/bin/kafka-server-start.sh \
    /opt/kafka/current/config/server.properties

# 后台运行
nohup /opt/kafka/current/bin/kafka-server-start.sh \
    /opt/kafka/current/config/server.properties > \
    /opt/kafka/logs/kafka.log 2>&1 &

# 验证启动
netstat -tlnp | grep 9092
# 应该看到端口9092被监听

启动验证包括检查端口监听、进程状态和日志内容。如果启动失败，首先检查kafka.log中的错误信息，常见问题包括ZooKeeper连接失败、端口冲突、配置错误、磁盘空间不足等。

🏗️ 多Broker集群配置

📋 集群架构规划

多Broker集群能提供高可用性和更好的性能。典型的测试集群包含3个Broker，运行在不同端口上。集群架构需要考虑分区副本分布、负载均衡和故障恢复。每个Broker有唯一的ID和监听端口，共享同一个ZooKeeper集群。

节点	地址	broker.id
ZooKeeper	localhost:2181	—
Broker1	localhost:9092	0
Broker2	localhost:9093	1
Broker3	localhost:9094	2

⚙️ 创建多个Broker配置

多Broker配置的核心是确保每个Broker有不同的ID、端口和数据目录。复制基础配置文件然后修改关键参数是最简单的方法。注意配置文件的命名规则，便于管理和识别。

# 复制基础配置
cp /opt/kafka/current/config/server.properties \
   /opt/kafka/current/config/server-1.properties

为每个Broker创建独立的配置文件，确保关键参数不重复。broker.id必须在集群中唯一，listeners和advertised.listeners要使用不同端口，log.dirs要使用不同目录避免数据冲突。

# 创建server-2.properties
cat > /opt/kafka/current/config/server-2.properties << EOF
broker.id=1
listeners=PLAINTEXT://localhost:9093
advertised.listeners=PLAINTEXT://localhost:9093
log.dirs=/opt/kafka/data/kafka-logs-2
zookeeper.connect=localhost:2181
EOF

# 创建server-3.properties
cat > /opt/kafka/current/config/server-3.properties << EOF
broker.id=2
listeners=PLAINTEXT://localhost:9094
advertised.listeners=PLAINTEXT://localhost:9094
log.dirs=/opt/kafka/data/kafka-logs-3
zookeeper.connect=localhost:2181
EOF

📁 创建数据目录

每个Broker需要独立的数据目录避免数据混淆。目录命名要清晰表明对应的Broker，便于运维管理。权限设置要统一，确保所有Kafka进程都能正常访问。

# 为每个Broker创建数据目录
mkdir -p /opt/kafka/data/kafka-logs-2
mkdir -p /opt/kafka/data/kafka-logs-3

# 设置权限
chmod -R 755 /opt/kafka/data/kafka-logs-*

🚀 启动集群

集群启动要按顺序进行，先启动ZooKeeper，然后依次启动各个Broker。每个Broker启动后稍作等待，确保完全启动后再启动下一个。这样可以避免同时启动时的资源竞争和初始化冲突。

# 启动所有Broker
nohup /opt/kafka/current/bin/kafka-server-start.sh \
    /opt/kafka/current/config/server.properties > \
    /opt/kafka/logs/kafka-1.log 2>&1 &

nohup /opt/kafka/current/bin/kafka-server-start.sh \
    /opt/kafka/current/config/server-2.properties > \
    /opt/kafka/logs/kafka-2.log 2>&1 &

nohup /opt/kafka/current/bin/kafka-server-start.sh \
    /opt/kafka/current/config/server-3.properties > \
    /opt/kafka/logs/kafka-3.log 2>&1 &

✅ 环境验证

🔍 验证服务状态

环境验证是确保集群正常工作的重要步骤。通过多种方式检查服务状态，包括网络端口、进程状态和日志内容。端口检查确认服务正在监听，进程检查确认服务正在运行，日志检查确认没有严重错误。

# 检查端口监听
netstat -tlnp | grep -E "(2181|9092|9093|9094)"

# 检查进程
ps aux | grep -E "(zookeeper|kafka)" | grep -v grep

# 检查日志
tail -n 50 /opt/kafka/logs/kafka.log

📝 创建测试Topic

创建Topic是验证Kafka集群功能的标准方式。测试Topic应该设置多个分区和副本，验证集群的分布式特性。分区数设置为3可以测试负载分布，副本数设置为3可以测试数据冗余和故障恢复。

# 创建测试Topic
/opt/kafka/current/bin/kafka-topics.sh \
    --create \
    --topic test-topic \
    --bootstrap-server localhost:9092 \
    --partitions 3 \
    --replication-factor 3

# 验证Topic创建
/opt/kafka/current/bin/kafka-topics.sh \
    --list \
    --bootstrap-server localhost:9092

Topic创建成功后，可以通过describe命令查看详细信息，包括分区分布、副本位置和领导者分布。这些信息有助于理解Kafka的内部工作机制。

📤 生产消费测试

生产消费测试是验证消息传递功能的直接方法。使用控制台工具可以快速验证基本功能；先启动消费者便于观察实时消息，但并非接收消息的必要条件。下文使用--from-beginning，在新消费组没有已提交偏移量且消息仍被保留时，也可以读取先前生产的消息。测试时发送不同类型的消息，包括中文消息，验证编码处理是否正确。

# 终端1：启动消费者
/opt/kafka/current/bin/kafka-console-consumer.sh \
    --topic test-topic \
    --bootstrap-server localhost:9092 \
    --from-beginning

# 终端2：启动生产者
/opt/kafka/current/bin/kafka-console-producer.sh \
    --topic test-topic \
    --bootstrap-server localhost:9092

# 输入测试消息
> Hello Kafka!
> This is a test message
> 消息传递成功！

如果消费者能实时接收到生产者发送的消息，说明环境搭建成功。可以尝试停止某个Broker，验证故障转移是否正常工作。

🔧 性能优化配置

💾 JVM参数调优

JVM参数对Kafka性能有重要影响。堆内存大小要根据消息处理量和缓存需求设置，通常1-2GB足够。垃圾收集器选择G1GC适合低延迟场景，ParallelGC适合高吞吐量场景。GC参数调优要根据实际监控数据进行，避免过度优化。

# 编辑Kafka启动脚本
vim /opt/kafka/current/bin/kafka-server-start.sh

# 添加JVM参数
export KAFKA_HEAP_OPTS="-Xmx1G -Xms1G"
export KAFKA_JVM_PERFORMANCE_OPTS="-server -XX:+UseG1GC -XX:MaxGCPauseMillis=20 -XX:InitiatingHeapOccupancyPercent=35 -XX:+ExplicitGCInvokesConcurrent -Djava.awt.headless=true"

📊 系统参数优化

系统级别的优化包括文件句柄限制、网络缓冲区和内核参数。文件句柄数量要足够支持大量连接和文件操作。网络缓冲区大小影响网络性能，需要根据消息大小和网络环境调整。这些参数修改后需要重启系统或重新登录才能生效。

# 编辑系统限制
sudo vim /etc/security/limits.conf

# 添加以下配置
kafka soft nofile 65536
kafka hard nofile 65536
kafka soft nproc 32768
kafka hard nproc 32768

# 网络参数优化
sudo vim /etc/sysctl.conf

# 添加以下配置
net.core.wmem_default = 262144
net.core.rmem_default = 262144
net.core.wmem_max = 16777216
net.core.rmem_max = 16777216
net.ipv4.tcp_wmem = 4096 87380 16777216
net.ipv4.tcp_rmem = 4096 87380 16777216

# 应用配置
sudo sysctl -p

🛠️ 管理脚本

📋 启动脚本

自动化脚本能大幅简化集群管理工作。启动脚本要考虑服务依赖关系，先启动ZooKeeper再启动Kafka。每个服务启动后要等待一段时间确保完全启动。脚本要包含错误处理和状态检查，提高可靠性。

#!/bin/bash
# kafka-cluster-start.sh

KAFKA_HOME=/opt/kafka/current

echo "Starting ZooKeeper..."
nohup $KAFKA_HOME/bin/zookeeper-server-start.sh \
    $KAFKA_HOME/config/zookeeper.properties > \
    $KAFKA_HOME/logs/zookeeper.log 2>&1 &

sleep 5

echo "Starting Kafka Brokers..."
for i in 1 2 3; do
    if [ $i -eq 1 ]; then
        config_file="server.properties"
    else
        config_file="server-$i.properties"
    fi
    
    nohup $KAFKA_HOME/bin/kafka-server-start.sh \
        $KAFKA_HOME/config/$config_file > \
        $KAFKA_HOME/logs/kafka-$i.log 2>&1 &
    
    echo "Broker $i start command submitted; readiness not checked"
    sleep 3
done

echo "Kafka cluster start commands submitted; verify service readiness and message delivery."

🛑 停止脚本

停止脚本要按照相反顺序停止服务，先停止Kafka再停止ZooKeeper。使用官方提供的停止脚本确保优雅关闭。停止后要检查进程是否真正结束，必要时使用kill命令强制终止。

#!/bin/bash
# kafka-cluster-stop.sh

KAFKA_HOME=/opt/kafka/current

echo "Stopping Kafka Brokers..."
$KAFKA_HOME/bin/kafka-server-stop.sh

sleep 5

echo "Stopping ZooKeeper..."
$KAFKA_HOME/bin/zookeeper-server-stop.sh

echo "Kafka cluster stop commands submitted; verify that all target processes have exited."

🔍 状态检查脚本

状态检查脚本提供集群健康状况的快速概览。包括端口监听、进程状态、Topic列表和磁盘使用情况。这个脚本可以定期执行或集成到监控系统中。

#!/bin/bash
# kafka-cluster-status.sh

echo "=== Kafka Cluster Status ==="
echo "1. Port Status:"
netstat -tlnp | grep -E "(2181|9092|9093|9094)"
echo "2. Process Status:"
ps aux | grep -E "(zookeeper|kafka)" | grep -v grep
echo "3. Topics List:"
/opt/kafka/current/bin/kafka-topics.sh \
    --list \
    --bootstrap-server localhost:9092
echo "4. Disk Usage:"
du -sh /opt/kafka/data/*

🚨 常见问题解决

❗ 启动失败

启动失败时首先查看日志文件定位具体错误。端口被占用是最常见的问题，通过lsof命令找到占用进程并终止。ZooKeeper未启动会导致Kafka无法连接，确保ZooKeeper先于Kafka启动。磁盘空间不足会导致写入失败，需要清理空间或增加存储。权限问题通过chown命令修复。

# 检查日志
tail -f /opt/kafka/logs/kafka.log

# 常见错误和解决方案：
# 1. 端口被占用
sudo lsof -i :9092
# 确认PID归属及停止影响后，优先通过对应服务管理方式停止
# 必须直接向已确认的进程发送信号时，先尝试正常终止
sudo kill -TERM <PID>
# 仅在正常终止失败且确认可接受强制终止风险时，才考虑SIGKILL

# 2. ZooKeeper未启动
ps aux | grep zookeeper

# 3. 磁盘空间不足
df -h

# 4. 权限问题
sudo chown -R $USER:$USER /opt/kafka

🔗 连接问题

客户端连接问题通常与网络配置相关。使用telnet测试网络连通性，检查防火墙设置确保端口开放。监听地址配置错误会导致外部无法访问，特别注意advertised.listeners参数必须是客户端可达的地址。

# 检查网络连接
telnet localhost 9092

# 检查防火墙
sudo ufw status
sudo firewall-cmd --list-ports

# 检查监听地址
netstat -tlnp | grep 9092

💾 数据丢失

数据丢失问题需要从多个角度排查。检查数据目录确认文件是否存在，磁盘空间不足可能导致数据无法写入。日志保留配置决定数据保留时间，过短的保留时间会导致数据被清理。副本配置不当也可能导致数据丢失。

# 检查数据目录
ls -la /opt/kafka/data/kafka-logs/

# 检查磁盘空间
df -h

# 检查日志配置
grep -E "(log.retention|log.segment)" \
    /opt/kafka/current/config/server.properties

✅ 掌握检查

完成以下检查，确保你已经成功搭建了Kafka环境：

• [ ] 成功安装并启动了ZooKeeper
• [ ] 成功启动了至少一个Kafka Broker
• [ ] 能够创建Topic并查看Topic列表
• [ ] 成功进行了生产者消费者测试
• [ ] 理解了主要的配置参数含义

🔗 学习连接

前置知识: Kafka与其他消息系统对比 - 了解Kafka的优势 下一步学习: 第一个Kafka程序 - 编写你的第一个Kafka应用程序 相关概念:

• Linux系统管理
• JVM调优
• 网络配置

---