diff --git a/trustgraph-base/trustgraph/base/logging.py b/trustgraph-base/trustgraph/base/logging.py
index bf4941aa..7bab6091 100644
--- a/trustgraph-base/trustgraph/base/logging.py
+++ b/trustgraph-base/trustgraph/base/logging.py
@@ -133,10 +133,14 @@ def setup_logging(args):
             print(f"WARNING: Failed to setup Loki logging: {e}")
             print("Continuing with console-only logging")
 
+    # Get processor ID for log formatting (use 'unknown' if not available)
+    processor_id = args.get('id', 'unknown')
+
     # Configure logging with all handlers
+    # Use processor ID as the primary identifier in logs
     logging.basicConfig(
         level=getattr(logging, log_level.upper()),
-        format='%(asctime)s - %(name)s - %(levelname)s - %(message)s',
+        format=f'%(asctime)s - {processor_id} - %(levelname)s - %(message)s',
         handlers=handlers,
         force=True  # Force reconfiguration if already configured
     )
diff --git a/trustgraph-flow/trustgraph/gateway/service.py b/trustgraph-flow/trustgraph/gateway/service.py
index 5bc1113f..3ebed6af 100755
--- a/trustgraph-flow/trustgraph/gateway/service.py
+++ b/trustgraph-flow/trustgraph/gateway/service.py
@@ -168,6 +168,12 @@ def run():
         description=__doc__
     )
 
+    parser.add_argument(
+        '--id',
+        default='api-gateway',
+        help='Service identifier for logging and metrics (default: api-gateway)',
+    )
+
     parser.add_argument(
         '-p', '--pulsar-host',
         default=default_pulsar_host,