docs: public static void setOffsetInZooKeeper(CuratorFramework curatorClient, String groupId, String topic, int partition, long offset) throws Exception {
  		ZKGroupTopicDirs topicDirs = new ZKGroupTopicDirs(groupId, topic);
  		String path = topicDirs.consumerOffsetDir() + "/" + partition;
  		curatorClient.newNamespaceAwareEnsurePath(path).ensure(curatorClient.getZookeeperClient());
  		byte[] data = Long.toString(offset).getBytes(ConfigConstants.DEFAULT_CHARSET);
  		curatorClient.setData().forPath(path, data);
  	}