Fix kafka connection string

theodolite-quarkus/src/main/kotlin/theodolite/execution/TheodoliteExecutor.kt

@@ -5,10 +5,7 @@ import theodolite.k8s.UC1Benchmark
 import theodolite.strategies.restriction.LowerBoundRestriction
 import theodolite.strategies.searchstrategy.CompositeStrategy
 import theodolite.strategies.searchstrategy.LinearSearch
-import theodolite.util.Config
-import theodolite.util.LoadDimension
-import theodolite.util.Resource
-import theodolite.util.Results
+import theodolite.util.*
 import java.nio.file.Paths
 import java.time.Duration
 
@@ -20,9 +17,9 @@ class TheodoliteExecutor() {
     private fun loadConfig(): Config {
         logger.info { resourcesPath }
         val benchmark: UC1Benchmark = UC1Benchmark(
-            UC1Benchmark.UC1BenchmarkConfig(
+            AbstractBenchmark.Config(
                 clusterZookeeperConnectionString = "my-confluent-cp-zookeeper:2181",
-                clusterKafkaConnectionString = "localhost:9092",
+                clusterKafkaConnectionString = "my-confluent-cp-kafka:9092",
                 externalZookeeperConnectionString = "localhost:2181",
                 externalKafkaConnectionString = "localhost:9092",
                 schemaRegistryConnectionString = "http://my-confluent-cp-schema-registry:8081",

theodolite-quarkus/src/main/kotlin/theodolite/k8s/UC1Benchmark.kt

@@ -12,7 +12,7 @@ import theodolite.util.Resource
 
 private val logger = KotlinLogging.logger {}
 
-class UC1Benchmark(config: AbstractBenchmarkConfig) : AbstractBenchmark(config) {
+class UC1Benchmark(config: Config) : AbstractBenchmark(config) {
     private val workloadGeneratorStateCleaner: WorkloadGeneratorStateCleaner
     private val topicManager: TopicManager
 

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

 package theodolite.util
 
-import theodolite.k8s.UC1Benchmark
-
-abstract class AbstractBenchmark(val config: AbstractBenchmarkConfig): Benchmark {
+abstract class AbstractBenchmark(val config: Config): Benchmark {
     override fun start(load: LoadDimension, resources: Resource) {
         this.clearClusterEnvironment()
         this.initializeClusterEnvironment()
@@ -10,7 +8,7 @@ abstract class AbstractBenchmark(val config: AbstractBenchmarkConfig): Benchmark
         this.startWorkloadGenerator(load)
     }
 
-    data class AbstractBenchmarkConfig(
+    data class Config(
         val clusterZookeeperConnectionString: String,
         val clusterKafkaConnectionString: String,
         val externalZookeeperConnectionString: String,