Modify log INFO with offset and new results per poll iteration

castorm · May 28, 2020 · b71c6fc · b71c6fc
1 parent ffc7fea
commit b71c6fc
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -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;
     }