diff --git a/theodolite-quarkus/src/main/kotlin/theodolite/benchmark/KubernetesBenchmark.kt b/theodolite-quarkus/src/main/kotlin/theodolite/benchmark/KubernetesBenchmark.kt
index 7c06856a8434db9d8ab9f7511c5fb5fcc148b375..cef47a556bfb29060f1698101f76329175dcdc4e 100644
--- a/theodolite-quarkus/src/main/kotlin/theodolite/benchmark/KubernetesBenchmark.kt
+++ b/theodolite-quarkus/src/main/kotlin/theodolite/benchmark/KubernetesBenchmark.kt
@@ -46,7 +46,7 @@ class KubernetesBenchmark(): Benchmark {
             resources = resources.map { r -> r.second },
             kafkaConfig = hashMapOf("bootstrap.servers" to kafkaConfig.bootstrapServer),
             zookeeperConfig = zookeeperConfig["server"].toString(),
-            topics = kafkaConfig.topics)
+            topics = kafkaConfig.getKafkaTopics())
     }
 }
 
diff --git a/theodolite-quarkus/src/main/kotlin/theodolite/util/KafkaConfig.kt b/theodolite-quarkus/src/main/kotlin/theodolite/util/KafkaConfig.kt
index f75927c0e947be7ecf6c273fac9633be79893a58..1ad2f1b21c85bdac48de6f21f478d4a509885f90 100644
--- a/theodolite-quarkus/src/main/kotlin/theodolite/util/KafkaConfig.kt
+++ b/theodolite-quarkus/src/main/kotlin/theodolite/util/KafkaConfig.kt
@@ -1,8 +1,19 @@
 package theodolite.util
 
 import org.apache.kafka.clients.admin.NewTopic
+import kotlin.properties.Delegates
 
 class KafkaConfig() {
     lateinit var bootstrapServer: String
-    lateinit var topics: List<NewTopic>
+    lateinit var topics: List<TopicWrapper>
+
+    fun getKafkaTopics(): List<NewTopic> {
+        return topics.map { topic -> NewTopic(topic.name, topic.numPartitions, topic.replicationFactor) }
+    }
+
+    class TopicWrapper {
+        lateinit var name: String
+        var numPartitions by Delegates.notNull<Int>()
+        var replicationFactor by Delegates.notNull<Short>()
+    }
 }
\ No newline at end of file
diff --git a/theodolite-quarkus/src/main/resources/yaml/testBenchmarkType.yaml b/theodolite-quarkus/src/main/resources/yaml/testBenchmarkType.yaml
index de1db3c71b5a59253ed47cbe04ffeca5062d3f01..dc820e4655002ca45b109fcdda50874f156624f4 100644
--- a/theodolite-quarkus/src/main/resources/yaml/testBenchmarkType.yaml
+++ b/theodolite-quarkus/src/main/resources/yaml/testBenchmarkType.yaml
@@ -21,7 +21,7 @@ kafkaConfig:
   bootstrapServer: "localhost:31290"
   topics:
     - name: "input"
-      partition: "1"
-      replication: "1"
+      numPartitions: 1
+      replicationFactor: 1
 zookeeperConfig:
   server: "localhost:31953"
\ No newline at end of file