bump version of memobase-kafka-utils

build.gradle

@@ -32,7 +32,7 @@ ext {
 }
 
 dependencies {
-    implementation 'ch.memobase:memobase-kafka-utils:0.1.2'
+    implementation 'ch.memobase:memobase-kafka-utils:0.1.3'
     implementation 'org.memobase:memobase-service-utilities:0.16.0'
     implementation 'ch.memobase:mapper-service-configuration:0.3.4'
     // Logging Framework
@@ -88,4 +88,4 @@ plugins.withType(DistributionPlugin) {
     distTar {
         archiveFileName = 'app.tar'
     }
-}
\ No newline at end of file
+}

src/main/kotlin/App.kt

@@ -18,8 +18,8 @@
 
 package org.memobase
 
-import org.apache.logging.log4j.LogManager
 import kotlin.system.exitProcess
+import org.apache.logging.log4j.LogManager
 
 class App {
     companion object {

src/main/kotlin/KafkaTopology.kt

@@ -93,7 +93,6 @@ class KafkaTopology(
             .mapValues { value -> buildResources(value) }
             .mapValues { value -> value.extractRecordId() }
 
-
         val extractedRecordTypeValueStream = extractRecordId(extractedRecordIdStream)
 
         val hasIdAndTypeStream = extractRecordTypeValue(extractedRecordTypeValueStream)
@@ -205,4 +204,4 @@ class KafkaTopology(
             Triple(null, null, Report(key, ReportStatus.failure, ex.localizedMessage))
         }
     }
-}
\ No newline at end of file
+}

src/main/kotlin/Service.kt

@@ -41,4 +41,4 @@ class Service(file: String = "app.yml") {
             throw Exception("Stream stopped running!")
         }
     }
-}
\ No newline at end of file
+}