diff --git a/src/main/java/org/eclipse/dataplane/Dataplane.java b/src/main/java/org/eclipse/dataplane/Dataplane.java
index 7b68030..6ce7aa0 100644
--- a/src/main/java/org/eclipse/dataplane/Dataplane.java
+++ b/src/main/java/org/eclipse/dataplane/Dataplane.java
@@ -132,6 +132,7 @@ public Result<DataFlowStatusMessage> prepare(String controlplaneId, DataFlowPrep
                 .counterPartyId(message.counterPartyId())
                 .dataspaceContext(message.dataspaceContext())
                 .controlplaneId(controlplaneId)
+                .type(DataFlow.Type.CONSUMER)
                 .build();
 
         return checkControlPlane(controlplaneId)
@@ -166,6 +167,7 @@ public Result<DataFlowStatusMessage> start(String controlplaneId, DataFlowStartM
                 .counterPartyId(message.counterPartyId())
                 .dataspaceContext(message.dataspaceContext())
                 .controlplaneId(controlplaneId)
+                .type(DataFlow.Type.PROVIDER)
                 .build();
 
         return checkControlPlane(controlplaneId)
diff --git a/src/main/java/org/eclipse/dataplane/domain/dataflow/DataFlow.java b/src/main/java/org/eclipse/dataplane/domain/dataflow/DataFlow.java
index efec334..c5efead 100644
--- a/src/main/java/org/eclipse/dataplane/domain/dataflow/DataFlow.java
+++ b/src/main/java/org/eclipse/dataplane/domain/dataflow/DataFlow.java
@@ -39,6 +39,7 @@ public class DataFlow {
     private Map<String, Object> metadata;
     private DataAddress dataAddress;
     private String controlplaneId;
+    private Type type;
 
     public static DataFlow.Builder newInstance() {
         return new Builder();
@@ -162,6 +163,14 @@ public String getControlplaneId() {
         return controlplaneId;
     }
 
+    public Type getType() {
+        return type;
+    }
+
+    public enum Type {
+        PROVIDER, CONSUMER
+    }
+
     public static class Builder {
         private final DataFlow dataFlow = new DataFlow();
 
@@ -243,6 +252,11 @@ public Builder controlplaneId(String controlplaneId) {
             dataFlow.controlplaneId = controlplaneId;
             return this;
         }
+
+        public Builder type(Type type) {
+            dataFlow.type = type;
+            return this;
+        }
     }
 
     public enum State {