Apache - Kafka存储工具
Apache - Kafka存储工具
提问于 2021-07-29 18:10:06
在文档中提到：
正如上面在QuickStart部分中所描述的，您必须使用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用不同的程序而不是用<uuid>程序生成kafka-storage.sh会不会是个问题？
回答 1
Stack Overflow用户
回答已采纳
发布于 2021-07-29 18:13:25
它需要一个与Kafka的内部UUID不匹配的类型-4 UUID
来自卡夫卡源代码
/**
* 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());
}页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/68581003
复制相关文章
相似问题
腾讯云开发者
