diff --git a/docs/zh/07-develop/07-tmq.mdx b/docs/zh/07-develop/07-tmq.mdx
index 6ab08b97d23d425b072ee991c092d62eba7e0cef..c9ac17808175841cd048d06a9460a8e1bb44bd51 100644
--- a/docs/zh/07-develop/07-tmq.mdx
+++ b/docs/zh/07-develop/07-tmq.mdx
@@ -134,7 +134,7 @@ func (c *Consumer) Unsubscribe() error
 
 <TabItem value="C#" label="C#">
 
-```C#
+```csharp
 ConsumerBuilder(IEnumerable<KeyValuePair<string, string>> config)
 
 virtual IConsumer Build()
@@ -158,6 +158,26 @@ void Close()
 
 </TabItem>
 
+<TabItem label="Node.JS" value="Node.JS">
+
+```node
+function TMQConsumer(config)
+
+function subscribe(topic)
+
+function consume(timeout)
+
+function subscription()
+
+function unsubscribe()
+
+function commit(msg)
+
+function close()
+```
+
+</TabItem>
+
 </Tabs>
 
 ## 写入数据
@@ -376,7 +396,7 @@ if err != nil {
 
 <TabItem value="C#" label="C#">
 
-```C#
+```csharp
 using TDengineTMQ;
 
 // 根据需要，设置消费组 (GourpId)、自动提交 (EnableAutoCommit)、
@@ -400,6 +420,28 @@ var consumer = new ConsumerBuilder(cfg).Build();
 
 </TabItem>
 
+<TabItem label="Node.JS" value="Node.JS">
+
+``` node
+// 根据需要，设置消费组 (group.id)、自动提交 (enable.auto.commit)、
+// 自动提交时间间隔 (auto.commit.interval.ms)、用户名 (td.connect.user)、密码 (td.connect.pass) 等参数 
+
+let consumer = taos.consumer({
+  'enable.auto.commit': 'true',
+  'auto.commit.interval.ms','1000',
+  'group.id': 'tg2',
+  'td.connect.user': 'root',
+  'td.connect.pass': 'taosdata',
+  'auto.offset.reset','earliest',
+  'msg.with.table.name': 'true',
+  'td.connect.ip','127.0.0.1',
+  'td.connect.port','6030'  
+  });
+
+```
+
+</TabItem>
+
 </Tabs>
 
 上述配置中包括 consumer group ID，如果多个 consumer 指定的 consumer group ID 一样，则自动形成一个 consumer group，共享消费进度。
@@ -448,7 +490,7 @@ if err != nil {
 
 <TabItem value="C#" label="C#">
 
-```C#
+```csharp
 // 创建订阅 topics 列表
 List<String> topics = new List<string>();
 topics.add("tmq_topic");
@@ -464,6 +506,18 @@ consumer = TaosConsumer('topic_ctb_column', group_id='vg2')
 ```
 </TabItem>
 
+<TabItem label="Node.JS" value="Node.JS">
+
+```node
+// 创建订阅 topics 列表
+let topics = ['topic_test']
+
+// 启动订阅
+consumer.subscribe(topics);
+```
+
+</TabItem>
+
 </Tabs>
 
 ## 消费
@@ -523,7 +577,7 @@ for {
 
 <TabItem value="C#" label="C#">
 
-```C#
+```csharp
 // 消费数据
 while (true)
 {
@@ -535,6 +589,21 @@ while (true)
 ```
 
 </TabItem>
+
+<TabItem label="Node.JS" value="Node.JS">
+
+```node
+while(true){
+   msg = consumer.consume(200);
+   // process message(consumeResult)
+   console.log(msg.topicPartition);
+   console.log(msg.block);
+   console.log(msg.fields)
+   }
+```
+
+</TabItem>
+
 </Tabs>
 
 ## 结束消费
@@ -585,7 +654,7 @@ consumer.Close()
 </TabItem>
 <TabItem value="C#" label="C#">
 
-```C#
+```csharp
 // 取消订阅
 consumer.Unsubscribe();
 
@@ -594,6 +663,15 @@ consumer.Close();
 ```
 </TabItem>
 
+<TabItem label="Node.JS" value="Node.JS">
+
+```node
+consumer.unsubscribe();
+consumer.close();
+```
+
+</TabItem>
+
 </Tabs>
 
 ## 删除 *topic*