diff options
| author | Paul-Christian Volkmer | 2023-08-03 12:59:53 +0200 |
|---|---|---|
| committer | Paul-Christian Volkmer | 2023-08-03 12:59:53 +0200 |
| commit | ac91620651daa2f9aa09709eaa0bb5a8f7222e71 (patch) | |
| tree | 1ac6ab217404b5f1cfb84429558cca0ecd2ea758 /src/main/kotlin/dev/dnpm/etl | |
| parent | 577509e6f2d502d4dbbf1a1b526c43497fde56b3 (diff) | |
Use Map as status body since it contains JSON
Diffstat (limited to 'src/main/kotlin/dev/dnpm/etl')
| -rw-r--r-- | src/main/kotlin/dev/dnpm/etl/processor/services/kafka/KafkaResponseProcessor.kt | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/main/kotlin/dev/dnpm/etl/processor/services/kafka/KafkaResponseProcessor.kt b/src/main/kotlin/dev/dnpm/etl/processor/services/kafka/KafkaResponseProcessor.kt index d6c4da6..547833c 100644 --- a/src/main/kotlin/dev/dnpm/etl/processor/services/kafka/KafkaResponseProcessor.kt +++ b/src/main/kotlin/dev/dnpm/etl/processor/services/kafka/KafkaResponseProcessor.kt @@ -54,7 +54,7 @@ class KafkaResponseProcessor( it.processedAt = Instant.ofEpochMilli(data.timestamp()) it.report = Report( "Warnungen über mangelhafte Daten", - responseBody.statusBody + objectMapper.writeValueAsString(responseBody.statusBody) ) requestRepository.save(it) } @@ -64,7 +64,7 @@ class KafkaResponseProcessor( it.processedAt = Instant.ofEpochMilli(data.timestamp()) it.report = Report( "Fehler bei der Datenübertragung oder Inhalt nicht verarbeitbar", - responseBody.statusBody + objectMapper.writeValueAsString(responseBody.statusBody) ) requestRepository.save(it) } @@ -83,6 +83,6 @@ class KafkaResponseProcessor( data class ResponseBody( @JsonProperty("status_code") @JsonAlias("status code") val statusCode: Int, - @JsonProperty("status_body") val statusBody: String + @JsonProperty("status_body") val statusBody: Map<String, Any> ) }
\ No newline at end of file |