Unverified Commit 8be2ff6a authored by Sebastian Schüpbach's avatar Sebastian Schüpbach
Browse files

more logs

parent ea8bd776
Pipeline #19286 passed with stages
in 6 minutes and 29 seconds
......@@ -20,7 +20,7 @@
<Configuration status="info" name="media-converter" packages="">
<Appenders>
<Console name="STDOUT" target="SYSTEM_OUT">
<PatternLayout pattern="[%-5level] [%c{1}:%L] %m%n"/>
<PatternLayout pattern="[%-5level] [%c{1}] %m%n"/>
</Console>
</Appenders>
<Loggers>
......
......@@ -63,6 +63,7 @@ object App extends scala.App with Logging with RecordUtils {
val records = consumer.poll(Duration.ofMillis(consumerPollTimeoutMs)).asScala
records.foreach {
record => {
logger.info(s"Build record ${record.key()}") // TODO: Remove
val headers = record.headers()
val recordSetHeader = Try(headers.lastHeader("recordSetId")).toOption
val institutionHeader = Try(headers.lastHeader("institutionId")).toOption
......@@ -82,6 +83,7 @@ object App extends scala.App with Logging with RecordUtils {
ReportingObject.addResourceOutcome(reportingObject, (resource, s"$msg: ${ex.getMessage}"), ProcessingFatal)
})
reporter.send(reportingObject, recordSetHeader, institutionHeader)
logger.info(s"Record ${record.key()} sent") // TODO: Remove
}
}
}
......
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