updated logging

Author: bachuv

samples/scenarios/WorkItemFilteringSplitActivitiesJava/client/src/main/java/io/durabletask/samples/Client.java

@@ -26,7 +26,7 @@ public static void main(String[] args) throws Exception {
         String connectionString = ConnectionHelper.getConnectionString();
 
         logger.info("=== Work Item Filtering Demo — Client ===");
-        logger.info("Connection: {}", connectionString);
+        logger.info("Connection: {}", ConnectionHelper.redact(connectionString));
 
         // Create the Durable Task client
         DurableTaskClient client = DurableTaskSchedulerClientExtensions

samples/scenarios/WorkItemFilteringSplitActivitiesJava/infra/core/host/container-app.bicep

@@ -114,7 +114,7 @@ resource app 'Microsoft.App/containerApps@2025-01-01' = {
   tags: tags
   // It is critical that the identity is granted ACR pull access before the app is created
   // otherwise the container app will throw a provision error
-  // This also forces us to use an user assigned managed identity since there would no way to 
+  // This also forces us to use a user assigned managed identity since there would no way to 
   // provide the system assigned identity with the ACR pull access before the app is created
   dependsOn: usePrivateRegistry ? [ containerRegistryAccess ] : []
   identity: {

samples/scenarios/WorkItemFilteringSplitActivitiesJava/orchestrator-worker/src/main/java/io/durabletask/samples/OrchestratorWorker.java

@@ -23,7 +23,7 @@ public final class OrchestratorWorker {
     public static void main(String[] args) throws IOException, InterruptedException {
         String connectionString = ConnectionHelper.getConnectionString();
 
-        logger.info("[Orchestrator] Connection: {}", connectionString);
+        logger.info("[Orchestrator] Connection: {}", ConnectionHelper.redact(connectionString));
         logger.info("[Orchestrator] This worker registers ONLY the orchestration. No activities.");
 
         // Build the worker with only the orchestration registered.

samples/scenarios/WorkItemFilteringSplitActivitiesJava/shared/src/main/java/io/durabletask/samples/ConnectionHelper.java

@@ -17,6 +17,24 @@ final class ConnectionHelper {
     private ConnectionHelper() {
     }
 
+    /**
+     * Returns a redacted version of a connection string safe for logging.
+     * Preserves Endpoint, TaskHub, and Authentication but redacts ClientID and other sensitive fields.
+     */
+    static String redact(String connectionString) {
+        if (connectionString == null) return "";
+        StringBuilder sb = new StringBuilder();
+        for (String part : connectionString.split(";")) {
+            String key = part.split("=", 2)[0].trim();
+            if (key.equalsIgnoreCase("Endpoint") || key.equalsIgnoreCase("TaskHub")
+                    || key.equalsIgnoreCase("Authentication")) {
+                if (sb.length() > 0) sb.append(';');
+                sb.append(part);
+            }
+        }
+        return sb.toString();
+    }
+
     static String getConnectionString() {
         String connectionString = System.getenv("DURABLE_TASK_CONNECTION_STRING");
         if (connectionString != null) {

samples/scenarios/WorkItemFilteringSplitActivitiesJava/shipper-worker/src/main/java/io/durabletask/samples/ShipperWorker.java

@@ -24,7 +24,7 @@ public final class ShipperWorker {
     public static void main(String[] args) throws IOException, InterruptedException {
         String connectionString = ConnectionHelper.getConnectionString();
 
-        logger.info("[Shipper] Connection: {}", connectionString);
+        logger.info("[Shipper] Connection: {}", ConnectionHelper.redact(connectionString));
         logger.info("[Shipper] This worker registers ONLY the ShipOrder activity.");
 
         // Build the worker with only the ShipOrder activity registered.

samples/scenarios/WorkItemFilteringSplitActivitiesJava/validator-worker/src/main/java/io/durabletask/samples/ValidatorWorker.java

@@ -23,7 +23,7 @@ public final class ValidatorWorker {
     public static void main(String[] args) throws IOException, InterruptedException {
         String connectionString = ConnectionHelper.getConnectionString();
 
-        logger.info("[Validator] Connection: {}", connectionString);
+        logger.info("[Validator] Connection: {}", ConnectionHelper.redact(connectionString));
         logger.info("[Validator] This worker registers ONLY the ValidateOrder activity.");
 
         // Build the worker with only the ValidateOrder activity registered.