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

ZookeeperConnector.getCommittedOffsetGroupPath介绍

暂无

代码示例

代码示例来源：origin: pinterest/secor

private String getCommittedOffsetTopicPath(String topic) {
  return getCommittedOffsetGroupPath() + "/" + topic;
}

代码示例来源：origin: pinterest/secor

public List<String> getCommittedOffsetTopics() throws Exception {
  ZooKeeper zookeeper = mZookeeperClient.get();
  String offsetPath = getCommittedOffsetGroupPath();
  List<String> topics = zookeeper.getChildren(offsetPath, false);
  LinkedList<String> result = new LinkedList<String>();
  for (String topicPath : topics) {
    String[] elements = topicPath.split("/");
    String topic = elements[elements.length - 1];
    result.add(topic);
  }
  return result;
}

代码示例来源：origin: pinterest/secor

protected void verify(String zookeeperPath, String expectedOffsetPath) {
    ZookeeperConnector zookeeperConnector = new ZookeeperConnector();
    PropertiesConfiguration properties = new PropertiesConfiguration();
    properties.setProperty("kafka.zookeeper.path", zookeeperPath);
    properties.setProperty("secor.kafka.group", "secor_cg");
    SecorConfig secorConfig = new SecorConfig(properties);
    zookeeperConnector.setConfig(secorConfig);
    Assert.assertEquals(expectedOffsetPath, zookeeperConnector.getCommittedOffsetGroupPath());
  }
}