Cloning the message content to prevent data race

noctarius · Oct 1, 2023 · 0b78967 · 0b78967
1 parent 05da944
commit 0b78967
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/internal/replication/logicalreplicationresolver/transactiontracker.go b/internal/replication/logicalreplicationresolver/transactiontracker.go
@@ -18,6 +18,7 @@
 package logicalreplicationresolver
 
 import (
+ "bytes"
  "github.com/jackc/pglogrepl"
  "github.com/noctarius/timescaledb-event-streamer/internal/containers"
  "github.com/noctarius/timescaledb-event-streamer/internal/logging"
@@ -378,6 +379,10 @@ func (tt *transactionTracker) OnMessageEvent(
  xld pgtypes.XLogData, msg *pgtypes.LogicalReplicationMessage,
 ) error {
 
+ // Clone content to release the original array which seems to be a slice of the
+ // original byte array from pgx
+ msg.Content = bytes.Clone(msg.Content)
+
  // If the message is transactional we need to store it into the currently collected
  // transaction, otherwise we can run it straight away.
  if msg.IsTransactional() {