*** a/src/backend/replication/logical/decode.c --- b/src/backend/replication/logical/decode.c *************** *** 458,463 **** DecodeCommit(LogicalDecodingContext *ctx, XLogRecordBuffer *buf, --- 458,465 ---- origin_lsn = parsed->origin_lsn; commit_time = parsed->origin_timestamp; } + else + commit_time = parsed->xact_time; /* * Process invalidation messages, even if we're not interested in the