DBZ-1565 Take empty messages into consideration
This commit is contained in:
parent
986dc4ef3a
commit
06ef4b6a95
@ -116,6 +116,7 @@ public void execute(ChangeEventSourceContext context) throws InterruptedExceptio
|
||||
LOGGER.trace("Received empty message");
|
||||
lastCompletelyProcessedLsn = lsn;
|
||||
offsetContext.updateWalPosition(lsn, lastCompletelyProcessedLsn, null, null, null, taskContext.getSlotXmin(connection));
|
||||
maybeWarnAboutGrowingWalBacklog(false);
|
||||
dispatcher.dispatchHeartbeatEvent(offsetContext);
|
||||
return;
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user