Unverified Commit 4839b1fc authored by Sebastian Schüpbach's avatar Sebastian Schüpbach
Browse files
parent 833da6b0
Pipeline #22378 passed with stages
in 5 minutes and 6 seconds
......@@ -45,9 +45,9 @@ object App
}
Report(record._1) match {
case Success(rep) if filters.forall(f => f(rep)) =>
logger.info("Match found")
logger.debug(s"${rep.recordId} matched!")
List(DeleteMessage(rep, sessionId))
case Success(r) =>
case Success(_) =>
List()
case Failure(_: ParserIgnore) =>
logger.debug("Ignoring irrelevant message")
......
/*
* Import Process Delete
* Copyright (C) 2020 Memoriav
* Copyright (C) 2021 Memoriav
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU Affero General Public License as published by
......@@ -29,7 +29,7 @@ abstract class KProducer {
private lazy val producer = new KafkaProducer[String, String](producerProps)
def sendDelete(id: DeleteMessage, dryRun: Boolean): Unit = {
logger.info(s"Sending delete command for $id")
logger.debug(s"Sending delete command for ${id.recordId}")
val producerRecord = new ProducerRecord[String, String](outputTopic, id.recordId, null)
producerRecord.headers()
.add("recordSetId", id.recordSetId.getBytes())
......
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