[.NET][Akri] full client Id provided by akri now, not just client id prefix (#802)

Author: timtay-microsoft

dotnet/src/Azure.Iot.Operations.Connector/Configurations/ConnectorFileMountSettings.cs

@@ -13,7 +13,7 @@ public class ConnectorFileMountSettings
         public const string ConnectorConfigMountPathEnvVar = "CONNECTOR_CONFIGURATION_MOUNT_PATH";
         public const string BrokerTrustBundleMountPathEnvVar = "BROKER_TLS_TRUST_BUNDLE_CACERT_MOUNT_PATH";
         public const string BrokerSatMountPathEnvVar = "BROKER_SAT_MOUNT_PATH";
-        public const string ConnectorClientIdEnvVar = "CONNECTOR_CLIENT_ID_PREFIX";
+        public const string ConnectorClientIdEnvVar = "CONNECTOR_ID";
 
         public const string ConnectorMqttConfigFileName = "MQTT_CONNECTION_CONFIGURATION";
         public const string ConnectorAioMetadataFileName = "AIO_METADATA";

dotnet/src/Azure.Iot.Operations.Connector/ConnectorWorker.cs

@@ -104,13 +104,6 @@ protected override async Task ExecuteAsync(CancellationToken cancellationToken)
                 }
             }
 
-            if (_leaderElectionConfiguration != null)
-            {
-                // Connector client id prefix is provided as environment variable, but it is the same prefix for all replicated pods.
-                // To avoid collision, add a suffix when replicating pods.
-                mqttConnectionSettings!.ClientId += Guid.NewGuid().ToString();
-            }
-
             _logger.LogInformation("Connecting to MQTT broker");
 
             await _mqttClient.ConnectAsync(mqttConnectionSettings!, cancellationToken);