diff --git a/jvm-runtime/ftl-runtime/java/deployment/src/main/java/xyz/block/ftl/javalang/deployment/JavaCodeGenerator.java b/jvm-runtime/ftl-runtime/java/deployment/src/main/java/xyz/block/ftl/javalang/deployment/JavaCodeGenerator.java
index b038887c0f..23b5c132d8 100644
--- a/jvm-runtime/ftl-runtime/java/deployment/src/main/java/xyz/block/ftl/javalang/deployment/JavaCodeGenerator.java
+++ b/jvm-runtime/ftl-runtime/java/deployment/src/main/java/xyz/block/ftl/javalang/deployment/JavaCodeGenerator.java
@@ -88,7 +88,7 @@ protected void generateTopicConsumer(Module module, Topic data, String packageNa
         var partitions = 1;
         for (var metadata : data.getMetadataList()) {
             if (metadata.hasPartitions()) {
-                partitions = (int)metadata.getPartitions().getPartitions();
+                partitions = (int) metadata.getPartitions().getPartitions();
                 break;
             }
         }
diff --git a/jvm-runtime/ftl-runtime/kotlin/deployment/src/main/java/xyz/block/ftl/kotlin/deployment/KotlinCodeGenerator.java b/jvm-runtime/ftl-runtime/kotlin/deployment/src/main/java/xyz/block/ftl/kotlin/deployment/KotlinCodeGenerator.java
index 9b66493796..196553ec0f 100644
--- a/jvm-runtime/ftl-runtime/kotlin/deployment/src/main/java/xyz/block/ftl/kotlin/deployment/KotlinCodeGenerator.java
+++ b/jvm-runtime/ftl-runtime/kotlin/deployment/src/main/java/xyz/block/ftl/kotlin/deployment/KotlinCodeGenerator.java
@@ -92,7 +92,7 @@ protected void generateTopicConsumer(Module module, Topic data, String packageNa
         var partitions = 1;
         for (var metadata : data.getMetadataList()) {
             if (metadata.hasPartitions()) {
-                partitions = (int)metadata.getPartitions().getPartitions();
+                partitions = (int) metadata.getPartitions().getPartitions();
                 break;
             }
         }