From 5b3f85ed3ba569a3cf867603d6747f991b5f5636 Mon Sep 17 00:00:00 2001
From: xleili <xlli@taosdata.com>
Date: Tue, 16 Aug 2022 15:22:09 +0800
Subject: [PATCH] docs(driver):update C# 3.0 tmq doc in develop/tmq.mdx

---
 docs/zh/07-develop/07-tmq.mdx | 90 +++++++++++++++++++++++++++++++++++
 1 file changed, 90 insertions(+)

diff --git a/docs/zh/07-develop/07-tmq.mdx b/docs/zh/07-develop/07-tmq.mdx
index f36f76fd85..957a8bbdda 100644
--- a/docs/zh/07-develop/07-tmq.mdx
+++ b/docs/zh/07-develop/07-tmq.mdx
@@ -87,6 +87,31 @@ void commitSync() throws SQLException;
 void close() throws SQLException;
 ```
 
+</TabItem>
+<TabItem value="C#" label="C#">
+
+```C#
+ConsumerBuilder(IEnumerable<KeyValuePair<string, string>> config)
+
+virtual IConsumer Build()
+
+Consumer(ConsumerBuilder builder)
+
+void Subscribe(IEnumerable<string> topics)
+
+void Subscribe(string topic) 
+
+ConsumeResult Consume(int millisecondsTimeout)
+
+List<string> Subscription()
+
+void Unsubscribe()
+ 
+void Commit(ConsumeResult consumerResult)
+
+void Close()
+```
+
 </TabItem>
 </Tabs>
 
@@ -229,6 +254,30 @@ public class MetersDeserializer extends ReferenceDeserializer<Meters> {
 }
 ```
 
+</TabItem>
+<TabItem value="C#" label="C#">
+
+```C#
+using TDengineTMQ;
+
+// 根据需要，设置消费组 (GourpId)、自动提交 (EnableAutoCommit)、
+// 自动提交时间间隔 (AutoCommitIntervalMs)、用户名 (TDConnectUser)、密码 (TDConnectPasswd) 等参数
+var cfg = new ConsumerConfig
+ {
+    EnableAutoCommit = "true"
+    AutoCommitIntervalMs = "1000"
+    GourpId = "TDengine-TMQ-C#",
+    TDConnectUser = "root",
+    TDConnectPasswd = "taosdata",
+    AutoOffsetReset = "earliest"
+    MsgWithTableName = "true",
+    TDConnectIp = "127.0.0.1",
+    TDConnectPort = "6030"
+ };
+
+var consumer = new ConsumerBuilder(cfg).Build();
+```
+
 </TabItem>
 </Tabs>
 
@@ -262,6 +311,18 @@ consumer.subscribe(topics);
 
 </TabItem>
 
+<TabItem value="C#" label="C#">
+
+```C#
+// 创建订阅 topics 列表
+List<String> topics = new List<string>();
+topics.add("tmq_topic");
+// 启动订阅
+consumer.Subscribe(topics);
+```
+
+</TabItem>
+
 </Tabs>
 
 ## 消费
@@ -296,6 +357,23 @@ while(running){
 </TabItem>
 </Tabs>
 
+<TabItem value="C#" label="C#">
+
+```C#
+// 消费数据
+while (true)
+{
+    var consumerRes = consumer.Consume(100);
+    // process ConsumeResult
+    ProcessMsg(consumerRes);
+    consumer.Commit(consumerRes);
+}
+```
+
+</TabItem>
+</Tabs>
+
+
 ## 结束消费
 
 消费结束后，应当取消订阅。
@@ -322,6 +400,18 @@ consumer.unsubscribe();
 consumer.close();
 ```
 
+</TabItem>
+
+<TabItem value="C#" label="C#">
+
+```C#
+// 取消订阅
+consumer.Unsubscribe();
+
+// 关闭消费
+consumer.Close();
+```
+
 </TabItem>
 </Tabs>
 
-- 
GitLab