Merge pull request #162 from rmsamitha/master

Fix duplicate event issue when data flow is slow
siddhi-io · Nov 2, 2023 · e3c50f6 · e3c50f6
2 parents 6daaef5 + 02df0fc
commit e3c50f6
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 4 deletions.
diff --git a/component/src/main/java/io/siddhi/extension/io/kafka/source/KafkaConsumerThread.java b/component/src/main/java/io/siddhi/extension/io/kafka/source/KafkaConsumerThread.java
@@ -126,7 +126,6 @@ void pause() {
     }
 
     void resume() {
-        restore();
         paused = false;
         try {
             lock.lock();

diff --git a/component/src/main/java/io/siddhi/extension/io/kafka/source/KafkaSource.java b/component/src/main/java/io/siddhi/extension/io/kafka/source/KafkaSource.java
@@ -440,10 +440,8 @@ public void pause() {
     public void resume() {
         if (consumerKafkaGroup != null) {
             consumerKafkaGroup.resume();
-            if (LOG.isDebugEnabled()) {
-                LOG.debug("Kafka Adapter resumed for topic(s): " + optionHolder.validateAndGetStaticValue
+            LOG.info("Kafka Adapter resumed for topic(s): " + optionHolder.validateAndGetStaticValue
                         (ADAPTOR_SUBSCRIBER_TOPIC));
-            }
         }
     }