本文整理了Java中com.taobao.metamorphosis.utils.ZkUtils.updatePersistentPath()
方法的一些代码示例,展示了ZkUtils.updatePersistentPath()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZkUtils.updatePersistentPath()
方法的具体详情如下:
包路径:com.taobao.metamorphosis.utils.ZkUtils
类名称:ZkUtils
方法名:updatePersistentPath
[英]Update the value of a persistent node with the given path and data. create parrent directory if necessary. Never throw NodeExistException.
[中]使用给定的路径和数据更新持久节点的值。如有必要,创建parrent目录。永远不要抛出nodeexist异常。
代码示例来源:origin: com.taobao.metamorphosis/metamorphosis-tools
public void setOffset(String topic, String group, Partition partition, String srcOffset) throws Exception {
String path = query.getOffsetPath(group, topic, partition);
ZkUtils.updatePersistentPath(this.query.getZkClient(), path, srcOffset);
}
}
代码示例来源:origin: com.taobao.metamorphosis/metamorphosis-client
ZkUtils.updatePersistentPath(this.zkClient, topicDirs.consumerOffsetDir + "/"
+ info.getPartition().toString(), msgId + "-" + newOffset);
内容来源于网络,如有侵权,请联系作者删除!