diff --git a/src/main/java/com/github/castorm/kafka/connect/http/HttpSourceTask.java b/src/main/java/com/github/castorm/kafka/connect/http/HttpSourceTask.java
index d0f94a13..26aa9e5e 100644
--- a/src/main/java/com/github/castorm/kafka/connect/http/HttpSourceTask.java
+++ b/src/main/java/com/github/castorm/kafka/connect/http/HttpSourceTask.java
@@ -104,7 +104,7 @@ public List<SourceRecord> poll() throws InterruptedException {
                 .filter(recordFilterFactory.create(offset))
                 .collect(toList());
 
-        log.info("Request for offset={} yields {}/{} unseen records", offset.toMap(), records.size(), filteredRecords.size());
+        log.info("Request for offset {} yields {}/{} new records", offset.toMap(), filteredRecords.size(), records.size());
 
         return filteredRecords;
     }