com.taobao.metamorphosis.utils.ZkUtils.updatePersistentPath()方法的使用及代码示例

x33g5p2x  于2022-02-05 转载在 其他  
字(1.0k)|赞(0)|评价(0)|浏览(132)

本文整理了Java中com.taobao.metamorphosis.utils.ZkUtils.updatePersistentPath()方法的一些代码示例,展示了ZkUtils.updatePersistentPath()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZkUtils.updatePersistentPath()方法的具体详情如下:
包路径:com.taobao.metamorphosis.utils.ZkUtils
类名称:ZkUtils
方法名:updatePersistentPath

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);

相关文章