kafkajs - npm Package Compare versions

Comparing version 1.13.0-beta.19 to 1.13.0-beta.20

package.json

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

src/admin/index.js

@@ -73,2 +73,11 @@ const createRetry = require('../retry')
   /**
+   * @return {Promise}
+   */
+  const listTopics = async () => {
+    const { topicMetadata } = await cluster.metadata()
+    const topics = topicMetadata.map(t => t.topic)
+    return topics
+  }
+
+  /**
    * @param {array} topics
@@ -805,2 +814,3 @@ * @param {boolean} [validateOnly=false]
     disconnect,
+    listTopics,
     createTopics,
@@ -807,0 +817,0 @@ deleteTopics,

No alert changes

Improved metrics

Total package byte prevSize

513351

0.04%

Lines of code

15194

0.06%

No dependency changes