zookeeper的获取kafka相应分区的offset（java语言）

Question

public List getOffSet(String topic) {
List results = null;
// zookeeper中保存partitions的路径
String partitions = "/consumers/group1/offsets/help/0";
System.out.println(partitions);
///consumers/[groupId]/offsets/[topic]/[partitionId] -> long (offset)
try {
// 获取子节点
results = this.zookeeper.getChildren(partitions, true);
} catch (KeeperException e) {
e.printStackTrace();
} catch (InterruptedException e) {
e.printStackTrace();
}
return results;
}

Answer 1

blic List getOffSet(String topic) {
List results = null;
// zookeeper中保存partitions的路径
String partitions = "/consumers/group1/offsets/help/0";
System.out.println(partitions);
///consumers/[groupId]/offsets/[topic]/[partitionId] -> long (offset)
try {
// 获取子节点
results = this.zookeeper.getChildren(partitions, true);
} catch (KeeperException e) {
e.printStackTrace();
} catch (InterruptedException e) {