diff --git a/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/admin/KafkatorioKafkaAdmin.kt b/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/admin/KafkatorioKafkaAdmin.kt
index a51916f..fb89dbc 100644
--- a/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/admin/KafkatorioKafkaAdmin.kt
+++ b/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/admin/KafkatorioKafkaAdmin.kt
@@ -1,5 +1,6 @@
 package dev.adamko.kafkatorio.processor.admin
 
+import dev.adamko.kafkatorio.events.schema.FactorioEventUpdate
 import dev.adamko.kafkatorio.events.schema.FactorioObjectData
 import dev.adamko.kafkatorio.events.schema.KafkatorioPacket
 import dev.adamko.kafkatorio.processor.KafkatorioTopology
@@ -42,10 +43,14 @@ object KafkatorioKafkaAdmin {
             }
           KafkatorioPacket.PacketType.CONFIG     -> add("$base.FactorioConfigurationUpdate")
           KafkatorioPacket.PacketType.PROTOTYPES -> add("$base.all")
-          KafkatorioPacket.PacketType.UPDATE     -> add("$base.all")
+          KafkatorioPacket.PacketType.UPDATE     -> {
+            add("$base.all")
+            FactorioEventUpdate.FactorioEventUpdateType.values.forEach { objectName ->
+              add("$base.${objectName.name}")
+            }
+          }
         }
 
-
       }
     }.minus(currentTopics.toSet())