diff --git a/data/src/main/kotlin/io/zeebe/zeeqs/data/entity/Timer.kt b/data/src/main/kotlin/io/zeebe/zeeqs/data/entity/Timer.kt
index c6a67859..c0fa596a 100644
--- a/data/src/main/kotlin/io/zeebe/zeeqs/data/entity/Timer.kt
+++ b/data/src/main/kotlin/io/zeebe/zeeqs/data/entity/Timer.kt
@@ -12,7 +12,7 @@ class Timer(
     val dueDate: Long,
     var repetitions: Int,
     val elementId: String,
-    val processInstanceKey: Long?,
+    var processInstanceKey: Long?,
     val elementInstanceKey: Long?,
     val processDefinitionKey: Long?
 ) {
diff --git a/hazelcast-importer/src/main/kotlin/io/zeebe/zeeqs/importer/hazelcast/HazelcastImporter.kt b/hazelcast-importer/src/main/kotlin/io/zeebe/zeeqs/importer/hazelcast/HazelcastImporter.kt
index c786ad40..337aa1ce 100644
--- a/hazelcast-importer/src/main/kotlin/io/zeebe/zeeqs/importer/hazelcast/HazelcastImporter.kt
+++ b/hazelcast-importer/src/main/kotlin/io/zeebe/zeeqs/importer/hazelcast/HazelcastImporter.kt
@@ -419,6 +419,7 @@ class HazelcastImporter(
             "TRIGGERED" -> {
                 entity.state = TimerState.TRIGGERED
                 entity.endTime = record.metadata.timestamp
+                entity.processInstanceKey = record.processInstanceKey
             }
             "CANCELED" -> {
                 entity.state = TimerState.CANCELED