Kafka 部署指南: Linux 系统

环境准备

  1. Java 环境: Kafka 依赖 Java 运行时环境，请确保系统已安装 Java 8 或更高版本。
  2. ZooKeeper: Kafka 使用 ZooKeeper 进行协调和管理，需先安装并启动 ZooKeeper 服务。

下载 Kafka

从 Apache Kafka 官网下载 Kafka 二进制包，并解压到指定目录。

配置 Kafka

  1. server.properties: 修改 Kafka 配置文件 config/server.properties，设置 broker.id、listeners、log.dirs 等参数。
  2. zookeeper.connect: 配置 Kafka 连接 ZooKeeper 集群的地址。

启动 Kafka

  1. 启动 ZooKeeper: 进入 ZooKeeper 安装目录，执行 bin/zkServer.sh start 命令启动 ZooKeeper 服务。
  2. 启动 Kafka: 进入 Kafka 安装目录，执行 bin/kafka-server-start.sh config/server.properties 命令启动 Kafka 服务。

验证 Kafka

  1. 创建主题: 使用 bin/kafka-topics.sh 命令创建 Kafka 主题。
  2. 发送消息: 使用 bin/kafka-console-producer.sh 命令向主题发送消息。
  3. 消费消息: 使用 bin/kafka-console-consumer.sh 命令消费主题中的消息。

扩展阅读

  • Apache Kafka 官方文档: https://kafka.apache.org/documentation/