kafka-observe
Advanced tools
Comparing version 2.1.1-beta-2 to 2.1.1-beta-3
@@ -6,3 +6,3 @@ const { filter } = require("rxjs/operators"); | ||
module.exports = { | ||
write: ({ producer }) => ({ topic, headers, event, payload, limit = 6666666 }) => { | ||
write: ({ producer }) => ({ topic, headers, event, payload, limit = 666666 }) => { | ||
// Divide by 3 because string char can have up to 4 (in rare cases) bytes per char | ||
@@ -9,0 +9,0 @@ const data = JSON.stringify(payload); |
{ | ||
"name": "kafka-observe", | ||
"version": "2.1.1-beta-2", | ||
"version": "2.1.1-beta-3", | ||
"description": "", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
32039