feat: add partitionId to ZeebePartition context

camunda · Sep 22, 2021 · d35fa57 · d35fa57
1 parent a1b31c4
commit d35fa57
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/broker/src/main/java/io/camunda/zeebe/broker/system/partitions/ZeebePartition.java b/broker/src/main/java/io/camunda/zeebe/broker/system/partitions/ZeebePartition.java
@@ -31,6 +31,7 @@
 import io.camunda.zeebe.util.startup.StartupStep;
 import java.util.ArrayList;
 import java.util.List;
+import java.util.Map;
 import java.util.Optional;
 import org.slf4j.Logger;
 
@@ -94,6 +95,13 @@ public PartitionAdminAccess createAdminAccess() {
     return new ZeebePartitionAdminAccess(actor, adminControl);
   }
 
+  @Override
+  protected Map<String, String> createContext() {
+    final var actorContext = super.createContext();
+    actorContext.put(ACTOR_PROP_PARTITION_ID, Integer.toString(context.getPartitionId()));
+    return actorContext;
+  }
+
   @Override
   public String getName() {
     return actorName;