diff --git a/synapse/replication/tcp/protocol.py b/synapse/replication/tcp/protocol.py
index 4f4d9915a8..75c9e8355f 100644
--- a/synapse/replication/tcp/protocol.py
+++ b/synapse/replication/tcp/protocol.py
@@ -242,6 +242,7 @@ class BaseReplicationStreamProtocol(LineOnlyReceiver):
     def send_error(self, error_string, *args):
         """Send an error to remote and close the connection.
         """
+        logger.error("[%s] Sending error: %s", self.id(), error_string % args)
         self.send_command(ErrorCommand(error_string % args))
         self.close()