(kafka-standalone): add interceptor class to the exposed configuration

Trendyol · May 10, 2024 · 6626ced · 6626ced
1 parent e213345
commit 6626ced
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 3 deletions.
diff --git a/...alone-example/src/test/kotlin/com/stove/spring/standalone/example/e2e/TestSystemConfig.kt b/...alone-example/src/test/kotlin/com/stove/spring/standalone/example/e2e/TestSystemConfig.kt
@@ -41,7 +41,7 @@ class TestSystemConfig : AbstractProjectConfig() {
             listOf(
               "kafka.bootstrapServers=${it.bootstrapServers}",
               "kafka.isSecure=false",
-              "kafka.interceptorClasses=com.trendyol.stove.testing.e2e.standalone.kafka.intercepting.StoveKafkaBridge"
+              "kafka.interceptorClasses=${it.interceptorClass}"
             )
           }
         }

diff --git a/.../main/kotlin/com/trendyol/stove/testing/e2e/standalone/kafka/KafkaExposedConfiguration.kt b/.../main/kotlin/com/trendyol/stove/testing/e2e/standalone/kafka/KafkaExposedConfiguration.kt
@@ -3,5 +3,6 @@ package com.trendyol.stove.testing.e2e.standalone.kafka
 import com.trendyol.stove.testing.e2e.system.abstractions.ExposedConfiguration
 
 data class KafkaExposedConfiguration(
-  val bootstrapServers: String
+  val bootstrapServers: String,
+  val interceptorClass: String
 ) : ExposedConfiguration
diff --git a/...-e2e-kafka/src/main/kotlin/com/trendyol/stove/testing/e2e/standalone/kafka/KafkaSystem.kt b/...-e2e-kafka/src/main/kotlin/com/trendyol/stove/testing/e2e/standalone/kafka/KafkaSystem.kt
@@ -49,7 +49,10 @@ class KafkaSystem(
   override suspend fun run() {
     exposedConfiguration = state.capture {
       context.container.start()
-      KafkaExposedConfiguration(context.container.bootstrapServers)
+      KafkaExposedConfiguration(
+        context.container.bootstrapServers,
+        StoveKafkaBridge::class.java.name
+      )
     }
     adminClient = createAdminClient(exposedConfiguration)
     kafkaPublisher = createPublisher(exposedConfiguration)