commit b4163e67cceeabb383e90faba86e4c1802c63093
author Naburun Nag <nag@cs.wisc.edu> Wed Feb 19 14:27:57 2020 -0800
committer Naburun Nag <nag@cs.wisc.edu> Wed Feb 19 14:27:57 2020 -0800
tree 6244b739765cae387a6027961fa9961157932a82
parent 2f30160df1c28d385bbade32256803fbc050a305

regEx improvements.

src/main/java/org/apache/geode/kafka/GeodeConnectorConfig.java

diff --git a/src/main/java/org/apache/geode/kafka/GeodeConnectorConfig.java b/src/main/java/org/apache/geode/kafka/GeodeConnectorConfig.java
index e1e7b64..452c59f 100644
--- a/src/main/java/org/apache/geode/kafka/GeodeConnectorConfig.java
+++ b/src/main/java/org/apache/geode/kafka/GeodeConnectorConfig.java
@@ -113,7 +113,7 @@
   public static List<String> parseBindings(String bindings) {
     return Arrays.stream(bindings.split("](\\s)*,")).map((s) -> {
       s = s.replaceAll("\\[", "");
-      s = s.replaceAll("\\]", "");
+      s = s.replaceAll("]", "");
       s = s.trim();
       return s;
     }).collect(Collectors.toList());

src/test/java/org/apache/geode/kafka/GeodeConnectorConfigTest.java

diff --git a/src/test/java/org/apache/geode/kafka/GeodeConnectorConfigTest.java b/src/test/java/org/apache/geode/kafka/GeodeConnectorConfigTest.java
index 34fc97b..7c6adef 100644
--- a/src/test/java/org/apache/geode/kafka/GeodeConnectorConfigTest.java
+++ b/src/test/java/org/apache/geode/kafka/GeodeConnectorConfigTest.java
@@ -77,7 +77,7 @@
     String binding = "[region1:topic1]";
     List<String> splitBindings = GeodeConnectorConfig.parseBindings(binding);
     assertEquals(1, splitBindings.size());
-    assertEquals(binding.replaceAll("\\[", "").replaceAll("\\]", ""), splitBindings.get(0));
+    assertEquals(binding.replaceAll("\\[", "").replaceAll("]", ""), splitBindings.get(0));
   }
 
   public List<String> oneToOneBindings() {