Source task: the collectedRecords must be counted as single entity even if the topics are multiple, because of camel batch size
@@ -153,8 +153,8 @@ public class CamelSourceTask extends SourceTask {
TaskHelper.logRecordContent(LOG, record, config);
records.add(record);
- collectedRecords++;
}
+ collectedRecords++;
} else {
break;
}
