fix servertime bug (#126)

Nextdoor · Dec 15, 2023 · 5925ff8 · 5925ff8
1 parent 0a9c5e3
commit 5925ff8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/replication/message.go b/replication/message.go
@@ -53,7 +53,7 @@ func XLogDataToWalMessage(xld pglogrepl.XLogData) (*WalMessage, error) {
 		uint64(xld.WALStart),
 		uint64(xld.ServerWALEnd),
 		// Note that in current postgres versions (9,10,11) ServerTime is unset and comes through as 0
-		int64(xld.ServerTime.Second()),
+		xld.ServerTime.UnixMilli(),
 		"",
 		pr,
 		"",