HelixUtils { public static void updateClusterConfig(HelixManager helixManager, String key, String value) { HelixConfigScope scope = newClusterConfigScope(helixManager); Map<String, String> properties = new HashMap<>(); properties.put(key, value); helixManager.getClusterManagmentTool().setConfig(scope, properties); }  static String getAbsoluteZkPathForHelix(String zkBaseUrl); static ZkHelixPropertyStore<ZNRecord> getZkPropertyStore(HelixManager helixManager,
      String clusterName); static Map<String, String> getInstanceToHostnameMap(HelixManager helixManager); static Map<String, HostAndPort> getInstanceToHostInfoMap(HelixManager helixManager); static List<String> liveInstances(HelixManager helixManager); static List<String> blacklistedInstances(HelixManager helixManager); static Map<String, Set<TopicPartition>> getInstanceToTopicPartitionsMap(
      HelixManager helixManager); static Map<String, Set<TopicPartition>> getInstanceToTopicPartitionsMap(
      HelixManager helixManager,
      Map<String, KafkaBrokerTopicObserver> clusterToObserverMap); static IdealState buildCustomIdealStateFor(String topicName,
      int numTopicPartitions,
      PriorityQueue<InstanceTopicPartitionHolder> instanceToNumServingTopicPartitionMap); static Map<String, IdealState> getIdealStatesFromAssignment(
      Set<InstanceTopicPartitionHolder> newAssignment,
      Set<TopicPartition> blacklistedTopicPartitions); static Set<TopicPartition> getUnassignedPartitions(HelixManager helixManager); static void updateClusterConfig(HelixManager helixManager, String key, String value); static boolean isClusterConfigEnabled(HelixManager helixManager, String key); static boolean isClusterConfigEnabled(HelixManager helixManager, String key,
      boolean defaultValue); static HelixConfigScope newClusterConfigScope(HelixManager helixManager);  }
@Test public void testUpdateClusterConfig() { HelixUtils.updateClusterConfig(_helixZkManager, Constants.AUTO_BALANCING, Constants.DISABLE); HelixConfigScope scope = HelixUtils.newClusterConfigScope(_helixZkManager); Map<String, String> config = _helixZkManager.getClusterManagmentTool() .getConfig(scope, Arrays.asList(Constants.AUTO_BALANCING)); Assert.assertTrue(config != null); Assert.assertTrue(config.containsKey(Constants.AUTO_BALANCING)); Assert.assertTrue(config.get(Constants.AUTO_BALANCING).equalsIgnoreCase(Constants.DISABLE)); }