4.2. 以 KRaft 模式运行 Kafka 集群

流程

1. 使用 kafka-storage 工具为 Kafka 集群生成 ID：

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

   Copy to Clipboard Toggle word wrap

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

2. 为集群中的每个代理创建配置属性文件。

   您可以根据 Kafka 提供的示例为基础。

   1. 将角色指定为 broker、'controller 或 broker, controller

      例如，process.roles=broker，controller。

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

      例如，node.id=1。

   3. 指定一个 controller.quorum.voters 列表，格式为 <node_id>@<hostname:port>。

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

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 配置文件中指定的默认日志目录位置为 /tmp/kraft-combined-logs。您可以添加以逗号分隔的列表来设置多个日志目录。

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

   返回：

   number kafka.Kafka /opt/kafka/config/kraft/server.properties

   Copy to Clipboard Toggle word wrap