Bootstrap semantics Kafka Streams.

perkss · perkss · commit 5327e291f548 · 2021-01-23T12:30:43.000Z
diff --git a/kotlin-kafka-streams-examples/src/main/kotlin/com/perkss/kafka/reactive/KafkaStreamsApp.kt b/kotlin-kafka-streams-examples/src/main/kotlin/com/perkss/kafka/reactive/KafkaStreamsApp.kt
@@ -18,8 +18,8 @@ class KafkaStreamsApp(
 
     override fun run(vararg args: String) {
         logger.info("Running Kotlin Kakfa Streams")
-        // orderProcessingApp.start()
-        bootstrapSemantics.start()
+        orderProcessingApp.start()
+        //bootstrapSemantics.start()
     }
 }
 

Original file line number	Diff line number	Diff line change
`@@ -18,8 +18,8 @@ class KafkaStreamsApp(`
`18`	`18`
`19`	`19`	`override fun run(vararg args: String) {`
`20`	`20`	`logger.info("Running Kotlin Kakfa Streams")`
`21`		`- // orderProcessingApp.start()`
`22`		`- bootstrapSemantics.start()`
	`21`	`+ orderProcessingApp.start()`
	`22`	`+ //bootstrapSemantics.start()`
`23`	`23`	`}`
`24`	`24`	`}`
`25`	`25`