diff --git a/pymysqlreplication/binlogstream.py b/pymysqlreplication/binlogstream.py
index a9dd4c6d..9e7befbc 100644
--- a/pymysqlreplication/binlogstream.py
+++ b/pymysqlreplication/binlogstream.py
@@ -360,7 +360,7 @@ def __connect_to_stream(self):
         if self.slave_uuid:
             cur = self._stream_connection.cursor()
             cur.execute(
-                f"SET @slave_uuid = {self.slave_uuid}, @replica_uuid = {self.slave_uuid}"
+                f"SET @slave_uuid = '{self.slave_uuid}', @replica_uuid = '{self.slave_uuid}'"
             )
             cur.close()