feat: add partitionId to LogStreamImpl context

(cherry picked from commit a1b31c4)
camunda · Sep 24, 2021 · 73077fa · 73077fa
1 parent e28cab3
commit 73077fa
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/logstreams/src/main/java/io/camunda/zeebe/logstreams/impl/log/LogStreamImpl.java b/logstreams/src/main/java/io/camunda/zeebe/logstreams/impl/log/LogStreamImpl.java
@@ -29,6 +29,7 @@
 import java.util.ArrayList;
 import java.util.HashSet;
 import java.util.List;
+import java.util.Map;
 import java.util.Set;
 import java.util.function.BiConsumer;
 import org.slf4j.Logger;
@@ -77,6 +78,13 @@ public final class LogStreamImpl extends Actor
     readers = new ArrayList<>();
   }
 
+  @Override
+  protected Map<String, String> createContext() {
+    final var context = super.createContext();
+    context.put(ACTOR_PROP_PARTITION_ID, Integer.toString(partitionId));
+    return context;
+  }
+
   @Override
   public String getName() {
     return actorName;