目 录CONTENT

文章目录

Kafka 单节点模式部署

BKUN
2024-03-07 / 0 评论 / 0 点赞 / 702 阅读 / 871 字

🚀 Kafka 单机部署指南

这是一个简洁的 Kafka 单机部署指南,适用于 Linux 和 Windows 系统。以下步骤帮助你快速搭建 Kafka 环境,依赖 Zookeeper 运行。让我们开始吧!📜


1️⃣ 准备工作

1.1 下载 Kafka 安装包

  • 文件名kafka_2.12-2.2.2.tgz
  • 下载地址Kafka 官网

💡 提示:选择与 JDK 版本兼容的 Scala 版本(如 2.12)。

1.2 安装 JDK 并配置环境变量

  • 要求:JDK 8 或更高版本。
  • Linux 示例
    sudo yum install -y java-1.8.0-openjdk
    export JAVA_HOME=/usr/lib/jvm/java-1.8.0-openjdk
    export PATH=$JAVA_HOME/bin:$PATH
    
  • Windows 示例
    1. 下载 JDK 安装包并安装。
    2. 配置环境变量:
      • 变量名:JAVA_HOME,值:C:\Program Files\Java\jdk1.8.0_XXX
      • 添加到 Path%JAVA_HOME%\bin

📌 验证:运行 java -version 检查 JDK 是否正常。

1.3 安装 Zookeeper

Kafka 依赖 Zookeeper 管理元数据,需先部署。

  • 参考Zookeeper 单节点部署
  • 简单步骤
    1. 下载 Zookeeper(如 zookeeper-3.4.14.tar.gz)。
    2. 解压并配置 conf/zoo.cfg(默认端口 2181)。
    3. 启动 Zookeeper:
      nohup bin/zkServer.sh start > /dev/null 2>&1 &
      

验证:运行 bin/zkServer.sh status 确认启动成功。


2️⃣ 环境搭建

2.1 解压 Kafka 安装包

tar -zvxf kafka_2.12-2.2.2.tgz -C /app

📦 结果:解压到 /app/kafka_2.12-2.2.2

2.2 修改 Kafka 配置文件

编辑 server.properties 文件:

vim /app/kafka_2.12-2.2.2/config/server.properties

调整以下关键配置(其他保持默认):

# 监听地址(替换为实际主机名或 IP)
listeners=PLAINTEXT://hostname:9092
# 或者使用 IP
listeners=PLAINTEXT://192.168.1.100:9092
# 数据存储目录
log.dirs=/app/kafka_2.12-2.2.2/data
# Zookeeper 连接
zookeeper.connect=127.0.0.1:2181

⚠️ 注意

  • 确保 log.dirs 目录存在(可手动创建:mkdir -p /app/kafka_2.12-2.2.2/data)。
  • 替换 hostname192.168.1.100 为实际服务器地址。

2.3 启动 Kafka

  • Linux(后台运行):
    nohup /app/kafka_2.12-2.2.2/bin/kafka-server-start.sh /app/kafka_2.12-2.2.2/config/server.properties > /dev/null 2>&1 &
    
  • Windows(在 Kafka 根目录执行):
    .\bin\windows\kafka-server-start.bat .\config\server.properties
    

🌟 提示:Windows 需在 Kafka 根目录运行,避免路径错误。

2.4 检查 Kafka 启动状态

列出所有 Topic 验证 Kafka 是否正常运行:

/app/kafka_2.12-2.2.2/bin/kafka-topics.sh --list --zookeeper 127.0.0.1:2181

输出:若无报错,显示现有 Topic 列表(新安装为空)。


🔧 使用技巧

  1. 验证 Zookeeper:确保 Zookeeper 在 127.0.0.1:2181 运行,否则调整 zookeeper.connect
  2. 日志查看
    • Linux:tail -f /app/kafka_2.12-2.2.2/logs/server.log
    • Windows:检查 logs 目录下的日志文件。
  3. 创建测试 Topic
    /app/kafka_2.12-2.2.2/bin/kafka-topics.sh --create --zookeeper 127.0.0.1:2181 --replication-factor 1 --partitions 1 --topic test
    
  4. 停止 Kafka
    • Linux:bin/kafka-server-stop.sh
    • Windows:Ctrl+C 或关闭窗口。

📌 注意事项

  • 端口冲突:确保 9092(Kafka)和 2181(Zookeeper)端口未被占用。
  • 权限:Linux 下确保 data 目录有写权限(chmod -R 777 /app/kafka_2.12-2.2.2/data)。
  • 版本兼容:Kafka 2.2.2 需搭配 Zookeeper 3.4.x 或更高版本。
0

评论区