Skip to content

Commit

Permalink
Fix record counts.
Browse files Browse the repository at this point in the history
previously the record count could be wrong and reflect how much data the
worker was writting, independantly of the partition
  • Loading branch information
parisni committed Feb 9, 2024
1 parent b5de512 commit 4cd799a
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -683,7 +683,7 @@ private void callbackFile(String encodedPartition) {
fileCallback.ifPresent(fs -> fs.call(tp.topic(), encodedPartition,
commitFiles.get(encodedPartition), tp.partition(),
new DateTime(baseRecordTimestamp).withZone(timeZone),
new DateTime(currentTimestamp).withZone(timeZone), recordCount,
new DateTime(currentTimestamp).withZone(timeZone), recordCounts.get(encodedPartition),
new DateTime(time.milliseconds()).withZone(timeZone)));
}

Expand Down

0 comments on commit 4cd799a

Please sign in to comment.