*** 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
