fix creation of Kafka topics

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())
     }
 }
 

theodolite-quarkus/src/main/kotlin/theodolite/util/KafkaConfig.kt

 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

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