minor bug fix in config parsing (#56)

Author: laxmanchekka

kafka-streams-partitioners/weighted-group-partitioner/src/main/java/org/hypertrace/core/kafkastreams/framework/partitioner/GroupPartitionerBuilder.java

@@ -1,7 +1,7 @@
 package org.hypertrace.core.kafkastreams.framework.partitioner;
 
+import com.google.common.base.Joiner;
 import com.typesafe.config.Config;
-import com.typesafe.config.ConfigUtil;
 import java.util.function.BiFunction;
 import org.apache.kafka.streams.processor.StreamPartitioner;
 import org.hypertrace.core.grpcutils.client.GrpcChannelRegistry;
@@ -22,12 +22,12 @@ public StreamPartitioner<K, V> buildPartitioner(
       StreamPartitioner<K, V> delegatePartitioner,
       GrpcChannelRegistry channelRegistry) {
     String enabledConfigPath =
-        ConfigUtil.joinPath(GROUP_PARTITIONER_CONFIG_PREFIX, ENABLED_CONFIG_KEY);
+        Joiner.on(".").join(GROUP_PARTITIONER_CONFIG_PREFIX, ENABLED_CONFIG_KEY);
     // Use group partitioner only when explicitly enabled.
     if (appConfig.hasPath(enabledConfigPath) && appConfig.getBoolean(enabledConfigPath)) {
       String serviceConfigPath =
-          ConfigUtil.joinPath(
-              GROUP_PARTITIONER_CONFIG_PREFIX, GROUP_PARTITIONER_CONFIG_SERVICE_PREFIX);
+          Joiner.on(".")
+              .join(GROUP_PARTITIONER_CONFIG_PREFIX, GROUP_PARTITIONER_CONFIG_SERVICE_PREFIX);
       PartitionerConfigServiceCachingClient configServiceClient =
           new PartitionerConfigServiceCachingClient(
               appConfig.getConfig(serviceConfigPath), channelRegistry);

kafka-streams-partitioners/weighted-group-partitioner/src/test/java/org/hypertrace/core/kafkastreams/framework/partitioner/GroupPartitionerBuilderTest.java

@@ -8,10 +8,10 @@
 import static org.hypertrace.core.kafkastreams.framework.partitioner.PartitionerConfigServiceClientConfig.PORT_KEY;
 import static org.junit.jupiter.api.Assertions.*;
 
+import com.google.common.base.Joiner;
 import com.google.common.collect.Maps;
 import com.typesafe.config.Config;
 import com.typesafe.config.ConfigFactory;
-import com.typesafe.config.ConfigUtil;
 import java.util.Map;
 import java.util.function.BiFunction;
 import org.apache.kafka.streams.processor.StreamPartitioner;
@@ -90,6 +90,6 @@ private Config toConfig(String host, String port, String cacheDuration, String e
   }
 
   private void putIfNotNull(Map<String, String> configMap, String value, String... keyElements) {
-    configMap.put(ConfigUtil.joinPath(keyElements), value);
+    configMap.put(Joiner.on(".").join(keyElements), value);
   }
 }