diff --git a/trustgraph-base/trustgraph/base/consumer_spec.py b/trustgraph-base/trustgraph/base/consumer_spec.py
index 1bde250a..aaeca677 100644
--- a/trustgraph-base/trustgraph/base/consumer_spec.py
+++ b/trustgraph-base/trustgraph/base/consumer_spec.py
@@ -20,7 +20,7 @@ class ConsumerSpec(Spec):
             flow = flow,
             client = processor.client,
             topic = definition[self.name],
-            subscriber = flow.id + "---" + self.name,
+            subscriber = processor.id + "--" + self.name,
             schema = self.schema,
             handler = self.handler,
             metrics = consumer_metrics,