consider versioned records as well

13181aeb · Matthias · 16bc20f9 · 13181aeb
Commit 13181aeb authored Jan 07, 2021 by Matthias
Hide whitespace changes
Inline Side-by-side

Showing with 1 addition and 0 deletions

src/main/kotlin/KafkaTopology.kt src/main/kotlin/KafkaTopology.kt +1 -0

No files found.
--- a/src/main/kotlin/KafkaTopology.kt
+++ b/src/main/kotlin/KafkaTopology.kt
@@ -104,6 +104,7 @@ class KafkaTopology(

                    var outputTopic = settings.outputTopic + when (event.objectType) {
                        "rico:Record" -> "-json-records"
+                        "rico:VersionedRecord" -> "-json-records"
                        "rico:RecordSet" -> "-json-record-sets"
                        "rico:CorporateBody" -> "-json-institutions"
                        else -> "-XXX"