fix: add missing properties

* Add log name * Add node id
camunda-community-hub · Jan 21, 2022 · f4de12b · f4de12b
1 parent 4dd5388
commit f4de12b
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/eze/src/main/kotlin/org/camunda/community/eze/EngineFactory.kt b/eze/src/main/kotlin/org/camunda/community/eze/EngineFactory.kt
@@ -33,6 +33,8 @@ import java.util.concurrent.CompletableFuture
 
 typealias PartitionId = Int
 
+private const val LOGSTREAM_NAME = "EZE-LOG"
+
 object EngineFactory {
 
     private val partitionId: PartitionId = 1
@@ -123,6 +125,7 @@ object EngineFactory {
             .zeebeDb(database)
             .eventApplierFactory { EventAppliers(it) }
             .commandResponseWriter(grpcResponseWriter)
+            .nodeId(0)
             .streamProcessorFactory { context ->
                 EngineProcessors.createEngineProcessors(
                     context,
@@ -152,6 +155,7 @@ object EngineFactory {
         val builder = LogStream.builder()
             .withPartitionId(partitionId)
             .withLogStorage(logStorage)
+            .withLogName(LOGSTREAM_NAME)
             .withActorSchedulingService(scheduler)
 
         val theFuture = CompletableFuture<LogStream>()