String getClusterId() {
    try {
      return registry.getClusterId().get();
    } catch (InterruptedException | ExecutionException e) {
      LOG.error("Error fetching cluster ID: ", e);
    }
    return null;
  }
If choreService has not been created yet, create the ChoreService.
hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncConnectionImpl.java