Check array

Author: sam-lippert

producer.js

@@ -9,7 +9,7 @@ export const QueueProducer = (queue, env) => {
         return await env[queue].kafka.send(message.body || message)
       },
       sendBatch: async (messages) => {
-        return await env[queue].kafka.sendBatch(messages.map((m) => m.body || m))
+        return await env[queue].kafka.sendBatch(Array.isArray(messages) ? messages.map((m) => m.body || m) : messages.body || messages)
       },
     }
   }