使用go-zookeeper API创建TTL节点报错，添加FlagEphemeral后正常原因咨询

我在尝试创建TTL节点时遇到问题，执行CreateTTL函数时持续出现“invalid arguments”错误。已确认参数符合函数定义，但错误仍存在，调整TTL时长、节点路径、数据参数后依然报错。直到将flags修改为zk.FlagTTL|zk.FlagEphemeral才恢复正常，想咨询该现象的原因。

相关API代码 #

// CreateTTL creates a TTL znode, which will be automatically deleted by server after the TTL.
func (c *Conn) CreateTTL(path string, data []byte, flags int32, acl []ACL, ttl time.Duration) (string, error) {
    if err := validatePath(path, flags&FlagSequence == FlagSequence); err != nil {
        return "", err
    }
    if flags&FlagTTL != FlagTTL {
        return "", ErrInvalidFlags
    }

    res := &createResponse{}
    _, err := c.request(opCreateTTL, &CreateTTLRequest{path, data, acl, flags, ttl.Milliseconds()}, res, nil)
    return res.Path, err
}

我的代码 #

import "github.com/go-zookeeper/zk"
conn, _, err := zk.Connect( []string{"[***]:***"}, time.Second*5)
if err != nil {
     hlog.Errorf("[ZK] Connect returned error: %v", err)
}
res, err := conn.CreateTTL("/test", []byte("ttl node"), zk.FlagTTL, zk.WorldACL(zk.PermAll), time.Second)

原因分析 #

这个问题的核心在于ZooKeeper服务器端对TTL节点的硬性要求：TTL节点必须同时是临时节点（Ephemeral）。

虽然客户端的CreateTTL函数仅校验了flags中必须包含FlagTTL，但ZooKeeper服务端本身有更严格的规则：创建TTL节点时，必须同时指定EPHEMERAL和TTL两个标志位，否则直接返回"invalid arguments"错误。

你最初只传入zk.FlagTTL，不符合服务端规则，因此报错；添加zk.FlagEphemeral后，标志位满足了服务端对TTL节点的要求，节点创建成功。

另外补充：ZooKeeper的TTL节点功能默认关闭，需要在服务端启动时配置extendedTypesEnabled=true才能启用，从你修改flags后成功创建的情况来看，你的服务端已经开启了该配置。

内容的提问来源于stack exchange，提问作者SimpleMiant