[camel-kafka-connector] 03/03: Source task: the collectedRecords must be counted as single entity even if the topics are multiple, because of camel batch size

[ac...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch multiple-topics
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git

commit 036cb9cd3053d71e4f1bb7e33abdd0bde013ee8d
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Sep 2 13:14:02 2020 +0200

    Source task: the collectedRecords must be counted as single entity even if the topics are multiple, because of camel batch size
---
 core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java
index 399e6d8..d4e0810 100644
--- a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java
+++ b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java
@@ -153,8 +153,8 @@ public class CamelSourceTask extends SourceTask {
 
                     TaskHelper.logRecordContent(LOG, record, config);
                     records.add(record);
-                    collectedRecords++;
                 }
+                collectedRecords++;
             } else {
                 break;
             }