[geode-kafka-connector] branch master updated: regEx improvements.

[nnag]

This is an automated email from the ASF dual-hosted git repository.

nnag pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/geode-kafka-connector.git


The following commit(s) were added to refs/heads/master by this push:
     new b4163e6  regEx improvements.
b4163e6 is described below

commit b4163e67cceeabb383e90faba86e4c1802c63093
Author: Naburun Nag <n...@cs.wisc.edu>
AuthorDate: Wed Feb 19 14:27:57 2020 -0800

    regEx improvements.
---
 src/main/java/org/apache/geode/kafka/GeodeConnectorConfig.java     | 2 +-
 src/test/java/org/apache/geode/kafka/GeodeConnectorConfigTest.java | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

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 class GeodeConnectorConfig extends AbstractConfig {
   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());
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 @@ public class GeodeConnectorConfigTest {
     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() {