Skip to content

Commit

Permalink
update comment
Browse files Browse the repository at this point in the history
  • Loading branch information
osheroff committed Sep 9, 2023
1 parent 034f0bb commit 21b104e
Showing 1 changed file with 1 addition and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -64,8 +64,7 @@ public AbstractAsyncProducer(MaxwellContext context) {
@Override
public final void push(RowMap r) throws Exception {
Position position = r.getNextPosition();
// Rows that do not get sent to a target will be automatically marked as complete.
// We will attempt to commit a checkpoint up to the current row.
// Rows that do not get sent to the prodcuer will be automatically marked as complete.
if(!r.shouldOutput(outputConfig)) {
if ( position != null ) {
inflightMessages.addMessage(position, r.getTimestampMillis(), 0L);
Expand Down

0 comments on commit 21b104e

Please sign in to comment.