快速开始 - 服务端安装与部署 - 手动安装部署

在本项目中，Kafka主要用于处理消息内容的实时接收与分发。

安装Kafka

1. 环境准备

• Kafka 是用 Java 编写的，因此先安装 Java 1.8+

2. 下载Kafka

• 下载安装包：https://kafka.apache.org/downloads，选择合适的稳定版本下载。
• 将下载的压缩包解压到你想要安装的目录，例如 D:\kafka。

3. 启动 ZooKeeper

• 这里就使用了默认的ZooKeeper配置和server配置。
• 安装后进入到目录：kafka\bin\windows下，先启动ZooKeeper服务，再启动Kafka服务。

  #先启动zookeeper服务
  ./zookeeper-server-start.bat ../../config/zookeeper.properties

  # 再启动kafka服务
  ./kafka-server-start.bat ../../config/server.properties

4. 验证安装

创建topic

• 进入到目录：kafka\bin\windows 下

• 运行以下命令创建一个名为 test_topic 的 Kafka 主题：

  kafka-topics.bat --create --topic test_topic --bootstrap-server localhost:9092

• 如果看到类似以下信息，表示主题创建成功：

  Created topic test_topic.

发送消息

• 在同一个命令提示符窗口中，运行以下命令启动一个 Kafka 生产者，向 test_topic 主题发送消息：

    kafka-console-producer.bat --topic test_topic --bootstrap-server localhost:9092

• 在命令行输入一些消息，例如：

  Hello, Kafka!

接收消息

• 打开一个新的命令提示符（CMD）或 PowerShell

  kafka-console-consumer.bat --topic test_topic --bootstrap-server localhost:9092 --from-beginning

• 如果能看到之前生产者发送的消息，说明 Kafka 安装和配置成功。

5. 创建本项目需要的topic

• 打开一个新的命令提示符（CMD）或 PowerShell执行下面命令

  kafka-topics.bat --create --topic topic-netty-0 --bootstrap-server localhost:9092
  kafka-topics.bat --create --topic topic-netty-1 --bootstrap-server localhost:9092
  kafka-topics.bat --create --topic topic-netty-2 --bootstrap-server localhost:9092
  kafka-topics.bat --create --topic topic-netty-3 --bootstrap-server localhost:9092