Apache Kafka KRaft-Kafka存储工具

Question

在文档中提到：

如上文"快速启动"部分所述，您必须使用kafka-storage.sh工具为新群集生成群集ID，然后在启动节点之前在每个节点上运行format命令。

生成集群ID

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

格式化存储目录

./bin/kafka-storage.sh format -t <uuid> -c ./config/kraft/server.properties
Formatting /tmp/kraft-combined-logs

用不同的程序而不是用kafka-storage.sh程序生成<uuid>会有问题吗？

Answer 1

它需要是一个与Kafka的内部UUID不匹配的类型4 UUID

来自Kafka源代码

/**
* Static factory to retrieve a type 4 (pseudo randomly generated) UUID.
*/
public static Uuid randomUuid() {
java.util.UUID uuid = java.util.UUID.randomUUID();
while (uuid.equals(METADATA_TOPIC_ID_INTERNAL) || uuid.equals(ZERO_ID_INTERNAL)) {
uuid = java.util.UUID.randomUUID();
}
return new Uuid(uuid.getMostSignificantBits(), uuid.getLeastSignificantBits());
}