fix: check for erroneous events

rudderlabs · Oct 5, 2023 · 556641f · 556641f
1 parent a838984
commit 556641f
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/src/v0/destinations/kafka/transform.js b/src/v0/destinations/kafka/transform.js
@@ -6,6 +6,7 @@ const {
   getHashFromArray,
   removeUndefinedAndNullValues,
   getSuccessRespEvents,
+  getErrorRespEvents,
 } = require('../../util');
 // const { InstrumentationError } = require("../../util/errorTypes");
 
@@ -38,6 +39,10 @@ const filterConfigTopics = (message, destination) => {
 
 const batch = (destEvents) => {
   const respList = [];
+  if (!Array.isArray(destEvents) || destEvents.length <= 0) {
+    const respEvents = getErrorRespEvents(null, 400, 'Invalid event array');
+    return [respEvents];
+  }
 
   // Grouping the events by topic
   const groupedEvents = groupBy(destEvents, (event) => event.message.topic);