Merge pull request #162 from rmsamitha/master

Fix duplicate event issue when data flow is slow

Author: AnuGayan

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();

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));
-            }
         }
     }