Commit 05fe22a8 authored by Jonas Waeber's avatar Jonas Waeber
Browse files

merge

parents 4df0d3c1 4007aa9b
Pipeline #16564 passed with stages
in 4 minutes and 58 seconds
...@@ -88,4 +88,4 @@ plugins.withType(DistributionPlugin) { ...@@ -88,4 +88,4 @@ plugins.withType(DistributionPlugin) {
distTar { distTar {
archiveFileName = 'app.tar' archiveFileName = 'app.tar'
} }
} }
\ No newline at end of file
...@@ -18,8 +18,8 @@ ...@@ -18,8 +18,8 @@
package org.memobase package org.memobase
import org.apache.logging.log4j.LogManager
import kotlin.system.exitProcess import kotlin.system.exitProcess
import org.apache.logging.log4j.LogManager
class App { class App {
companion object { companion object {
......
...@@ -107,7 +107,6 @@ class KafkaTopology( ...@@ -107,7 +107,6 @@ class KafkaTopology(
.mapValues { value -> buildResources(value) } .mapValues { value -> buildResources(value) }
.mapValues { value -> value.extractRecordId() } .mapValues { value -> value.extractRecordId() }
val extractedRecordTypeValueStream = extractRecordId(extractedRecordIdStream) val extractedRecordTypeValueStream = extractRecordId(extractedRecordIdStream)
val hasIdAndTypeStream = extractRecordTypeValue(extractedRecordTypeValueStream) val hasIdAndTypeStream = extractRecordTypeValue(extractedRecordTypeValueStream)
...@@ -233,4 +232,4 @@ class KafkaTopology( ...@@ -233,4 +232,4 @@ class KafkaTopology(
Triple(null, null, Report(key, ReportStatus.failure, ex.localizedMessage)) Triple(null, null, Report(key, ReportStatus.failure, ex.localizedMessage))
} }
} }
} }
\ No newline at end of file
...@@ -41,4 +41,4 @@ class Service(file: String = "app.yml") { ...@@ -41,4 +41,4 @@ class Service(file: String = "app.yml") {
throw Exception("Stream stopped running!") throw Exception("Stream stopped running!")
} }
} }
} }
\ No newline at end of file
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment