diff options
| author | Paul-Christian Volkmer | 2023-08-10 13:35:35 +0200 |
|---|---|---|
| committer | Paul-Christian Volkmer | 2023-08-10 13:35:35 +0200 |
| commit | 002b0618cf813d48bbff2d287e16f607a4c73d73 (patch) | |
| tree | cd43002166fb9f05fc13250eabf714de09a12304 /src/main/kotlin/dev/dnpm/etl | |
| parent | 2b42a4d262a846feb1f82facbb151be9cabb57b4 (diff) | |
Add tests for KafkaMtbFileSender
Diffstat (limited to 'src/main/kotlin/dev/dnpm/etl')
| -rw-r--r-- | src/main/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSender.kt | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/main/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSender.kt b/src/main/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSender.kt index 9448e29..e7f9769 100644 --- a/src/main/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSender.kt +++ b/src/main/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSender.kt @@ -50,7 +50,7 @@ class KafkaMtbFileSender( } } catch (e: Exception) { logger.error("An error occurred sending to kafka", e) - MtbFileSender.Response(RequestStatus.UNKNOWN) + MtbFileSender.Response(RequestStatus.ERROR) } } @@ -79,7 +79,7 @@ class KafkaMtbFileSender( } } catch (e: Exception) { logger.error("An error occurred sending to kafka", e) - MtbFileSender.Response(RequestStatus.UNKNOWN) + MtbFileSender.Response(RequestStatus.ERROR) } } |