3.4. 在 KRaft 模式下运行 Kafka 集群

流程

1. 为 Kafka 集群生成唯一 ID。

   您可以使用 kafka-storage 工具进行此操作：

   /opt/kafka/bin/kafka-storage.sh random-uuid

   Copy to Clipboard Toggle word wrap

   该命令返回一个 ID。KRaft 模式需要一个集群 ID。

2. 为集群中的每个节点创建一个配置文件。

   您可以在 Kafka 提供的示例上构建该文件。

   1. 将角色指定为 代理、控制器 或代理 、控制器

      例如，为组合角色指定 process.roles=broker。

   2. 从 0 开始，为集群中的每个节点指定唯一的 node.id。

      例如，node.id=1。

   3. 以 < node_id>@<hostname:port> 格式指定 controller.quorum.voters 列表。

      例如，controller.quorum.voters=1@localhost:9093.

   4. 指定监听程序：

      • 为每个监听程序配置名称、主机名和端口。

        例如： listeners=PLAINTEXT:localhost:9092,CONTROLLER:localhost:9093。

      • 配置用于代理间通信的监听程序名称。

        例如，inter.broker.listener.name=PLAINTEXT。

      • 配置控制器仲裁使用的监听程序名称。

        例如，controller.listener.names=CONTROLLER。

      • 为每个监听程序配置名称、主机名和端口，这些监听程序公告给客户端以连接到 Kafka。

        例如, advertised.listeners=PLAINTEXT:localhost:9092。

3. 为 Kafka 集群中的每个节点设置日志目录：

   /opt/kafka/bin/kafka-storage.sh format -t <uuid> -c /opt/kafka/config/kraft/server.properties

   Copy to Clipboard Toggle word wrap

   返回：

   Formatting /tmp/kraft-combined-logs

   Copy to Clipboard Toggle word wrap

   将 <uuid> 替换为您生成的集群 ID。对集群中的每个节点使用相同的 ID。

   使用您为代理创建的属性文件应用代理配置。

   默认情况下，server.properties 配置文件中指定的日志目录(log.dirs)设置为 /tmp/kraft-combined-logs。/tmp 目录通常会在每次系统重启时清除，使其仅适用于开发环境。

   您可以添加以逗号分隔的列表来设置多个日志目录。

4. 启动每个 Kafka 节点。

   /opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/kraft/server.properties

   Copy to Clipboard Toggle word wrap

5. 检查 Kafka 是否正在运行：

   jcmd | grep kafka

   Copy to Clipboard Toggle word wrap

   返回：

   process ID kafka.Kafka /opt/kafka/config/kraft/server.properties

   Copy to Clipboard Toggle word wrap

   检查每个节点的日志，以确保它们已成功加入 KRaft 集群：

   tail -f /opt/kafka/logs/server.log

   Copy to Clipboard Toggle word wrap