In order to mitigate against the brute force attacks against Gitlab accounts, we are moving to all edu-ID Logins. We would like to remind you to link your account with your edu-id. Login will be possible only by edu-ID after November 30, 2021. Here you can find the instructions for linking your account.

If you don't have a SWITCH edu-ID, you can create one with this guide here

kind regards

Commit 0f175101 authored by Jonas Waeber's avatar Jonas Waeber
Browse files

Add some logging for successful processing.

parent 50b96787
Pipeline #33281 passed with stages
in 3 minutes and 58 seconds
......@@ -27,11 +27,13 @@ import org.apache.kafka.streams.KeyValue
import org.apache.kafka.streams.StreamsBuilder
import org.apache.kafka.streams.Topology
import org.apache.kafka.streams.kstream.Predicate
import org.apache.logging.log4j.LogManager
import org.memobase.models.Formats
import org.memobase.models.Message
import org.memobase.models.ReportMessages
class KafkaTopology(private val settings: SettingsLoader) {
private val log = LogManager.getLogger(this::class.java.name)
private val step = settings.appSettings.getProperty(Service.reportingStepNamePropName)
private val reader = SftpReader(settings.sftpSettings)
private val parser = TableParser(step)
......@@ -70,7 +72,9 @@ class KafkaTopology(private val settings: SettingsLoader) {
parsedTables
.filter { _, value -> value.report.status != ReportStatus.fatal }
.mapValues { value -> klaxon.toJsonString(value.value) }
.mapValues { value ->
log.info("Successfully processed message ${value.key}.")
klaxon.toJsonString(value.value) }
.to(settings.outputTopic)
return builder.build()
......
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