commit 9b97b9c6685df685d55ccfd759c05fe98841c4b8
author Marcin Czech <maczech@gmail.com> Thu Dec 12 21:47:36 2019 +0100
committer Marcin Czech <maczech@gmail.com> Tue Dec 24 14:04:52 2019 +0100
tree 640c8bbe55153038463641c9f9697ec2cda540da
parent bb28fbbb8fa488b0fbd7e4dd0ea70a320f50dd76

Fix issue with kafka subscribers properties

KafkaProperties class is formatting configuration parameters from camel
case to separeted by dot. This formatting is required by kafka producer
and consumer. KafkaSubscriberProperties must follow the same pattern.

Bug: Issue 12109
Change-Id: Iede3c9e35eb405ccb2ec9ade45aede811e83131a

src/main/java/com/googlesource/gerrit/plugins/kafka/config/KafkaSubscriberProperties.java

diff --git a/src/main/java/com/googlesource/gerrit/plugins/kafka/config/KafkaSubscriberProperties.java b/src/main/java/com/googlesource/gerrit/plugins/kafka/config/KafkaSubscriberProperties.java
index b50053f..c3fd917 100644
--- a/src/main/java/com/googlesource/gerrit/plugins/kafka/config/KafkaSubscriberProperties.java
+++ b/src/main/java/com/googlesource/gerrit/plugins/kafka/config/KafkaSubscriberProperties.java
@@ -33,10 +33,10 @@
     super(configFactory, pluginName);
 
     this.pollingInterval =
-        Integer.parseInt(getProperty("pollingIntervalMs", DEFAULT_POLLING_INTERVAL_MS));
-    this.groupId = getProperty("groupId");
+        Integer.parseInt(getProperty("polling.interval.ms", DEFAULT_POLLING_INTERVAL_MS));
+    this.groupId = getProperty("group.id");
     this.numberOfSubscribers =
-        Integer.parseInt(getProperty("numberOfSubscribers", DEFAULT_NUMBER_OF_SUBSCRIBERS));
+        Integer.parseInt(getProperty("number.of.subscribers", DEFAULT_NUMBER_OF_SUBSCRIBERS));
   }
 
   public Integer getPollingInterval() {