Hotfix 1.3.1 (#77)

* fixing a stupid dependency issue regarding StringUtils

missing dependency affected the repackaged jar. no issue when running the fat uber
jar of the connector. the problem went unnoticed during release preparation since the
E2E test was configured to run against the uber jar.

* fix #76 and call potential post processor coming next in the chain

Author: hpgrahsl

pom.xml

@@ -4,7 +4,7 @@
 
     <groupId>at.grahsl.kafka.connect</groupId>
     <artifactId>kafka-connect-mongodb</artifactId>
-    <version>1.3.0</version>
+    <version>1.3.1</version>
     <packaging>jar</packaging>
 
     <name>kafka-connect-mongodb</name>
@@ -62,6 +62,7 @@
         <confluent.connect.plugin.version>0.11.1</confluent.connect.plugin.version>
         <ok.http.version>3.14.0</ok.http.version>
         <yaml.beans.version>1.13</yaml.beans.version>
+        <apache.commonslang3.version>3.8.1</apache.commonslang3.version>
         <nexus.staging.maven.plugin.version>1.6.8</nexus.staging.maven.plugin.version>
         <maven.source.plugin.version>3.0.1</maven.source.plugin.version>
         <maven.javadoc.plugin.version>3.1.0</maven.javadoc.plugin.version>
@@ -190,6 +191,11 @@
             <version>${yaml.beans.version}</version>
             <scope>test</scope>
         </dependency>
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-lang3</artifactId>
+            <version>${apache.commonslang3.version}</version>
+        </dependency>
     </dependencies>
 
     <distributionManagement>

src/main/java/at/grahsl/kafka/connect/mongodb/MongoDbSinkTask.java

@@ -31,7 +31,7 @@
 import com.mongodb.client.model.BulkWriteOptions;
 import com.mongodb.client.model.WriteModel;
 
-import org.apache.commons.lang.StringUtils;
+import org.apache.commons.lang3.StringUtils;
 import org.apache.kafka.clients.consumer.OffsetAndMetadata;
 import org.apache.kafka.common.TopicPartition;
 import org.apache.kafka.connect.errors.ConnectException;

src/main/java/at/grahsl/kafka/connect/mongodb/processor/field/renaming/Renamer.java

@@ -82,6 +82,8 @@ public void process(SinkDocument doc, SinkRecord orig) {
             doc.getValueDoc().ifPresent(vd -> doRenaming(PATH_PREFIX_VALUE, vd));
         }
 
+        getNext().ifPresent(pp -> pp.process(doc, orig));
+
     }
 
 }