diff --git a/src/backend/distributed/replication/multi_logical_replication.c b/src/backend/distributed/replication/multi_logical_replication.c
index d4e87db0b..59e5c350f 100644
--- a/src/backend/distributed/replication/multi_logical_replication.c
+++ b/src/backend/distributed/replication/multi_logical_replication.c
@@ -1674,7 +1674,7 @@ CreatePublications(MultiConnection *connection,
 		bool prefixWithComma = false;
 
 		appendStringInfo(createPublicationCommand, "CREATE PUBLICATION %s FOR TABLE ",
-						 entry->name);
+						 quote_identifier(entry->name));
 
 		ShardInterval *shard = NULL;
 		foreach_ptr(shard, entry->shardIntervals)
@@ -1840,8 +1840,8 @@ CreateSubscriptions(MultiConnection *sourceConnection,
 				"SET LOCAL citus.enable_ddl_propagation TO OFF;",
 				psprintf(
 					"CREATE USER %s SUPERUSER IN ROLE %s;",
-					target->subscriptionOwnerName,
-					GetUserNameFromId(ownerId, false)
+					quote_identifier(target->subscriptionOwnerName),
+					quote_identifier(GetUserNameFromId(ownerId, false))
 					)));
 
 		StringInfo conninfo = makeStringInfo();
@@ -1885,8 +1885,8 @@ CreateSubscriptions(MultiConnection *sourceConnection,
 		pfree(createSubscriptionCommand);
 		ExecuteCriticalRemoteCommand(target->superuserConnection, psprintf(
 										 "ALTER SUBSCRIPTION %s OWNER TO %s",
-										 target->subscriptionName,
-										 target->subscriptionOwnerName
+										 quote_identifier(target->subscriptionName),
+										 quote_identifier(target->subscriptionOwnerName)
 										 ));
 
 		/*
@@ -1899,7 +1899,7 @@ CreateSubscriptions(MultiConnection *sourceConnection,
 				"SET LOCAL citus.enable_ddl_propagation TO OFF;",
 				psprintf(
 					"ALTER ROLE %s NOSUPERUSER;",
-					target->subscriptionOwnerName
+					quote_identifier(target->subscriptionOwnerName)
 					)));
 	}
 }