Commit cb4d5746 authored by Jonas Waeber's avatar Jonas Waeber
Browse files

Update dependency

parent e63c6102
Pipeline #21410 passed with stages
in 3 minutes and 47 seconds
......@@ -33,7 +33,7 @@ ext {
dependencies {
implementation 'ch.memobase:memobase-kafka-utils:0.2.3'
implementation 'org.memobase:memobase-service-utilities:2.0.5'
implementation 'ch.memobase:mapper-service-configuration:1.0.1'
implementation 'ch.memobase:mapper-service-configuration:1.0.2'
// Logging Framework
implementation "org.apache.logging.log4j:log4j-api:${log4jV}"
implementation "org.apache.logging.log4j:log4j-core:${log4jV}"
......
......@@ -33,6 +33,7 @@ import ch.memobase.settings.HeaderMetadata
import ch.memobase.settings.SettingsLoader
import com.beust.klaxon.Klaxon
import com.beust.klaxon.KlaxonException
import org.apache.jena.riot.RDFFormat
import org.apache.kafka.common.serialization.Serdes
import org.apache.kafka.streams.KeyValue
import org.apache.kafka.streams.StreamsBuilder
......@@ -203,7 +204,7 @@ class KafkaTopology(
}
private fun writeRecord(builder: ResourceBuilder): KeyValue<String, Pair<String, Report>> {
val result = builder.writeRecord()
val result = builder.writeRecord(RDFFormat.NTRIPLES_UTF8)
return KeyValue(
result.first,
Pair(
......
Markdown is supported
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