DBZ-5962 Add comment explaning usage of the await without timeout

Also remove unneeded change in `pom.xml`.
spieps · Jan 17, 2023 · 81cd9be · 81cd9be
1 parent 15a19fa
commit 81cd9be
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/...ium-server-rocketmq/src/main/java/io/debezium/server/rocketmq/RocketMqChangeConsumer.java b/...ium-server-rocketmq/src/main/java/io/debezium/server/rocketmq/RocketMqChangeConsumer.java
@@ -153,7 +153,10 @@ public void onException(Throwable throwable) {
                 throw new DebeziumException(e);
             }
         }
+
+        // Messages have set default send timeout, so this will not block forever.
         latch.await();
+
         for (ChangeEvent<Object, Object> record : records) {
             committer.markProcessed(record);
         }

diff --git a/pom.xml b/pom.xml
@@ -139,7 +139,6 @@
         <!-- Infinispan version for Oracle and Debezium Server sink -->
         <version.infinispan>14.0.4.Final</version.infinispan>
         <version.infinispan.protostream>4.5.0.Final</version.infinispan.protostream>
-
     </properties>
 
     <modules>