Bootstrap semantics Kafka Streams.

Author: perkss

kotlin-kafka-streams-examples/src/main/kotlin/com/perkss/kafka/reactive/AppConfig.kt

@@ -115,11 +115,11 @@ class AppConfig {
         streamConfig: Properties
     ) = KafkaStreams(orderProcessingTopology, streamConfig)
 
-    @Bean
-    fun bootstrapSemantics(
-        streamsBuilder: StreamsBuilder,
-        streamConfig: Properties
-    ) = KafkaStreams(BootstrapSemanticsTopology.build(streamsBuilder, streamConfig), streamConfig)
+//    @Bean
+//    fun bootstrapSemantics(
+//        streamsBuilder: StreamsBuilder,
+//        streamConfig: Properties
+//    ) = KafkaStreams(BootstrapSemanticsTopology.build(streamsBuilder, streamConfig), streamConfig)
 
 
 }

kotlin-kafka-streams-examples/src/main/kotlin/com/perkss/kafka/reactive/KafkaStreamsApp.kt

@@ -9,7 +9,7 @@ import org.springframework.boot.runApplication
 @SpringBootApplication
 class KafkaStreamsApp(
     private val orderProcessingApp: KafkaStreams,
-    private val bootstrapSemantics: KafkaStreams
+   // private val bootstrapSemantics: KafkaStreams
 ) : CommandLineRunner {
 
     companion object {