diff --git a/components/electric/lib/electric/replication/postgres/slot_server.ex b/components/electric/lib/electric/replication/postgres/slot_server.ex
index 1db142b3ba..4fe17d9c7e 100644
--- a/components/electric/lib/electric/replication/postgres/slot_server.ex
+++ b/components/electric/lib/electric/replication/postgres/slot_server.ex
@@ -458,6 +458,13 @@ defmodule Electric.Replication.Postgres.SlotServer do
     }
   end
 
+  defp changes_to_wal(%Changes.Compensation{relation: table, record: new}, relations) do
+    %ReplicationMessages.Update{
+      relation_id: relations[table].oid,
+      tuple_data: record_to_tuple(new, relations[table].columns)
+    }
+  end
+
   defp changes_to_wal(
          %Changes.UpdatedRecord{relation: table, old_record: nil, record: new},
          relations