diff --git a/lib/kafka.js b/lib/kafka.js index 02c865e0..6d007009 100644 --- a/lib/kafka.js +++ b/lib/kafka.js @@ -56,7 +56,6 @@ async function sendMessage(params, topic) { topic, messages: [ { - key: 'key', value: JSON.stringify(params), }, ],