From d9dbf95c5eca2585bfabb1c8a3ded577bdcac9ec Mon Sep 17 00:00:00 2001
From: menshibin <men_shi_bin@163.com>
Date: Thu, 15 Aug 2024 13:37:06 +0800
Subject: [PATCH] modify exec error

---
 docs/examples/node/websocketexample/tmq_example.js      | 4 ++--
 docs/examples/node/websocketexample/tmq_seek_example.js | 4 ++--
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/docs/examples/node/websocketexample/tmq_example.js b/docs/examples/node/websocketexample/tmq_example.js
index b0e52360c9..fc9d2889e0 100644
--- a/docs/examples/node/websocketexample/tmq_example.js
+++ b/docs/examples/node/websocketexample/tmq_example.js
@@ -62,7 +62,7 @@ async function subscribe(consumer) {
             for (let [key, value] of res) {
                 console.log(`data: ${key} ${value}`);
             }
-            consumer.commit();
+            await consumer.commit();
             console.log("Commit offset manually successfully.");
         }
     } catch (err) {
@@ -77,7 +77,7 @@ async function test() {
     let consumer = null;
     try {
         await prepare();
-        let consumer = await createConsumer()
+        consumer = await createConsumer()
         await subscribe(consumer)
         await consumer.unsubscribe();
         console.log("Consumer unsubscribed successfully.");
diff --git a/docs/examples/node/websocketexample/tmq_seek_example.js b/docs/examples/node/websocketexample/tmq_seek_example.js
index 0dea7e1671..259614d5db 100644
--- a/docs/examples/node/websocketexample/tmq_seek_example.js
+++ b/docs/examples/node/websocketexample/tmq_seek_example.js
@@ -31,7 +31,7 @@ async function prepare() {
     conf.setUser('root');
     conf.setPwd('taosdata');
     conf.setDb('power');
-    const createDB = `CREATE DATABASE IF NOT EXISTS POWER ${db} KEEP 3650 DURATION 10 BUFFER 16 WAL_LEVEL 1;`;
+    const createDB = `CREATE DATABASE IF NOT EXISTS ${db} KEEP 3650 DURATION 10 BUFFER 16 WAL_LEVEL 1;`;
     const createStable = `CREATE STABLE IF NOT EXISTS ${db}.${stable} (ts timestamp, current float, voltage int, phase float) TAGS (location binary(64), groupId int);`;
 
     let wsSql = await taos.sqlConnect(conf);
@@ -45,7 +45,7 @@ async function prepare() {
     for (let i = 0; i < 10; i++) {
         await wsSql.exec(`INSERT INTO d1001 USING ${stable} (location, groupId) TAGS ("California.SanFrancisco", 3) VALUES (NOW, ${10 + i}, ${200 + i}, ${0.32 + i})`);
     }
-    wsSql.Close();
+    await wsSql.close();
 }
 
 // ANCHOR: subscribe