@514labs/moose-lib
Advanced tools
Comparing version 0.3.721 to 0.3.722
@@ -921,3 +921,3 @@ #!/usr/bin/env node | ||
logger.log( | ||
`Sending ${messageSize} bytes of a transformed record batch to ${args.targetTopic}` | ||
`Sending ${chunkSize} bytes of a transformed record batch to ${args.targetTopic}` | ||
); | ||
@@ -940,2 +940,5 @@ yield producer.send({ topic: args.targetTopic, messages: chunks }); | ||
if (chunks.length > 0) { | ||
logger.log( | ||
`Sending ${chunkSize} bytes of a transformed record batch to ${args.targetTopic}` | ||
); | ||
yield producer.send({ topic: args.targetTopic, messages: chunks }); | ||
@@ -1114,7 +1117,3 @@ logger.log( | ||
producer.on(producer.events.REQUEST, (event) => { | ||
if (event.payload.size > maxMessageSize) { | ||
logger.error( | ||
`Message size ${event.payload.size} exceeds max message size ${maxMessageSize}` | ||
); | ||
} | ||
logger.log(`Sending message size with ${event.payload.size}`); | ||
}); | ||
@@ -1121,0 +1120,0 @@ if (!has_no_output_topic(args)) { |
{ | ||
"name": "@514labs/moose-lib", | ||
"version": "0.3.721", | ||
"version": "0.3.722", | ||
"main": "./dist/index.js", | ||
@@ -5,0 +5,0 @@ "module": "./dist/index.mjs", |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
357240
3713