kafkajs - npm Package Compare versions

Comparing version 1.13.0-beta.32 to 1.13.0-beta.33

package.json

 {
   "name": "kafkajs",
-  "version": "1.13.0-beta.32",
+  "version": "1.13.0-beta.33",
   "description": "A modern Apache Kafka client for node.js",
@@ -82,5 +82,5 @@ "author": "Tulio Ornelas <[e-mail]>",
   "kafkajs": {
-    "sha": "01007496fa54c0cc8a00c48d91da569e2fae2e51",
-    "compare": "https://github.com/tulios/kafkajs/compare/v1.12.0...01007496fa54c0cc8a00c48d91da569e2fae2e51"
+    "sha": "a153f84b60b887d443a375bcbcb7b56720e5dcc7",
+    "compare": "https://github.com/tulios/kafkajs/compare/v1.12.0...a153f84b60b887d443a375bcbcb7b56720e5dcc7"
   }
 }

src/producer/sendMessages.js

@@ -21,5 +21,4 @@ const createRetry = require('../retry')
 
-    for (const { topic } of topicMessages) {
-      await cluster.addTargetTopic(topic)
-    }
+    const topics = topicMessages.map(({ topic }) => topic)
+    await cluster.addMultipleTargetTopics(topics)
 
@@ -26,0 +25,0 @@ const createProducerRequests = async responsePerBroker => {

No alert changes

Improved metrics

Total package byte prevSize

516262

0

Worsened metrics

Lines of code

15289

-0.01%

No dependency changes