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)
         }
     }