diff --git a/docs/zh/08-develop/01-connect/index.md b/docs/zh/08-develop/01-connect/index.md
index 528a30f909..ddf988435d 100644
--- a/docs/zh/08-develop/01-connect/index.md
+++ b/docs/zh/08-develop/01-connect/index.md
@@ -79,7 +79,7 @@ TDengine 提供了丰富的应用程序开发接口，为了便于用户快速
## 安装连接器
-
+
如果使用 Maven 管理项目，只需在 pom.xml 中加入以下依赖。
@@ -439,9 +439,6 @@ DSN 的详细说明和如何使用详见 [连接功能](../../reference/connecto
{{#include docs/examples/csharp/wsConnect/Program.cs:main}}
```
-
-
-
### 原生连接
@@ -496,16 +493,6 @@ DSN 的详细说明和如何使用详见 [连接功能](../../reference/connecto
{{#include docs/examples/go/connect/restexample/main.go}}
```
-
- 不支持
-
-
- 不支持
-
-
-
-
-
@@ -585,11 +572,6 @@ let taos = pool.get()?;
```
-
- 不支持
-
-
-
-
+
diff --git a/docs/zh/08-develop/04-schemaless.md b/docs/zh/08-develop/04-schemaless.md
index f25162a62a..afb622e157 100644
--- a/docs/zh/08-develop/04-schemaless.md
+++ b/docs/zh/08-develop/04-schemaless.md
@@ -204,8 +204,6 @@ writer.write(lineDemo, SchemalessProtocolType.LINE, SchemalessTimestampType.NANO
{{#include docs/examples/csharp/wssml/Program.cs:main}}
```
-
-
### 原生连接
@@ -249,30 +247,6 @@ writer.write(lineDemo, SchemalessProtocolType.LINE, SchemalessTimestampType.NANO
-
-### REST 连接
-
-
- 不支持
-
-
- 不支持
-
-
- 不支持
-
-
- 不支持
-
-
- 不支持
-
-
-
-
-
-
-
## 查询写入的数据
运行上节的样例代码，会在 power 数据库中自动建表，我们可以通过 taos shell 或者应用程序来查询数据。下面给出用 taos shell 查询超级表和 meters 表数据的样例。
diff --git a/docs/zh/08-develop/05-stmt.md b/docs/zh/08-develop/05-stmt.md
index 6cf8149fc6..e24e502a4b 100644
--- a/docs/zh/08-develop/05-stmt.md
+++ b/docs/zh/08-develop/05-stmt.md
@@ -60,9 +60,6 @@ import TabItem from "@theme/TabItem";
```csharp
{{#include docs/examples/csharp/wsStmt/Program.cs:main}}
```
-
-
-
diff --git a/docs/zh/08-develop/07-tmq.md b/docs/zh/08-develop/07-tmq.md
index f148dde9b2..fa6770a29f 100644
--- a/docs/zh/08-develop/07-tmq.md
+++ b/docs/zh/08-develop/07-tmq.md
@@ -145,10 +145,6 @@ Rust 连接器创建消费者的参数为 DSN， 可以设置的参数列表请
```csharp
{{#include docs/examples/csharp/wssubscribe/Program.cs:create_consumer}}
```
-
-
-
-
@@ -160,12 +156,10 @@ Rust 连接器创建消费者的参数为 DSN， 可以设置的参数列表请
-
```java
{{#include examples/JDBC/JDBCDemo/src/main/java/com/taosdata/example/ConsumerLoopFull.java:create_consumer}}
```
-
@@ -255,16 +249,19 @@ TMQ 消息队列是一个 [futures::Stream](https://docs.rs/futures/latest/futur
```
-
-
-
### 原生连接
-同 Websocket 代码样例。
+```java
+{{#include examples/JDBC/JDBCDemo/src/main/java/com/taosdata/example/WsConsumerLoopFull.java:poll_data_code_piece}}
+```
+
+- `subscribe` 方法的参数含义为：订阅的主题列表（即名称），支持同时订阅多个主题。
+- `poll` 每次调用获取一个消息，一个消息中可能包含多个记录。
+- `ResultBean` 是我们自定义的一个内部类，其字段名和数据类型与列的名称和数据类型一一对应，这样根据 `value.deserializer` 属性对应的反序列化类可以反序列化出 `ResultBean` 类型的对象。
@@ -282,7 +279,12 @@ TMQ 消息队列是一个 [futures::Stream](https://docs.rs/futures/latest/futur
-同 Websocket 示例代码
+消费者可订阅一个或多个 `TOPIC`，一般建议一个消费者只订阅一个 `TOPIC`。
+TMQ 消息队列是一个 [futures::Stream](https://docs.rs/futures/latest/futures/stream/index.html) 类型，可以使用相应 API 对每个消息进行消费，并通过 `.commit` 进行已消费标记。
+
+```rust
+{{#include docs/examples/rust/restexample/examples/tmq.rs:consume}}
+```
@@ -353,18 +355,20 @@ TMQ 消息队列是一个 [futures::Stream](https://docs.rs/futures/latest/futur
{{#include docs/examples/csharp/wssubscribe/Program.cs:seek}}
```
-
-
-
-
-
### 原生连接
-同 Websocket 代码样例。
+
+```java
+{{#include examples/JDBC/JDBCDemo/src/main/java/com/taosdata/example/WsConsumerLoopFull.java:consumer_seek}}
+```
+1. 使用 consumer.poll 方法轮询数据，直到获取到数据为止。
+2. 对于轮询到的第一批数据，打印第一条数据的内容，并获取当前消费者的分区分配信息。
+3. 使用 consumer.seekToBeginning 方法将所有分区的偏移量重置到开始位置，并打印成功重置的消息。
+4. 再次使用 consumer.poll 方法轮询数据，并打印第一条数据的内容。
@@ -382,7 +386,17 @@ TMQ 消息队列是一个 [futures::Stream](https://docs.rs/futures/latest/futur
-同 Websocket 代码样例。
+
+```rust
+{{#include docs/examples/rust/nativeexample/examples/tmq.rs:seek_offset}}
+```
+
+1. 通过调用 consumer.assignments() 方法获取消费者当前的分区分配信息，并记录初始分配状态。
+2. 遍历每个分区分配信息，对于每个分区：提取主题（topic）、消费组ID（vgroup_id）、当前偏移量（current）、起始偏移量（begin）和结束偏移量（end）。
+记录这些信息。
+1. 调用 consumer.offset_seek 方法将偏移量设置到起始位置。如果操作失败，记录错误信息和当前分配状态。
+2. 在所有分区的偏移量调整完成后，再次获取并记录消费者的分区分配信息，以确认偏移量调整后的状态。
+
@@ -446,10 +460,6 @@ TMQ 消息队列是一个 [futures::Stream](https://docs.rs/futures/latest/futur
```csharp
{{#include docs/examples/csharp/wssubscribe/Program.cs:commit_offset}}
```
-
-
-
-
@@ -458,7 +468,9 @@ TMQ 消息队列是一个 [futures::Stream](https://docs.rs/futures/latest/futur
-同 Websocket 代码样例。
+```java
+{{#include examples/JDBC/JDBCDemo/src/main/java/com/taosdata/example/WsConsumerLoopFull.java:commit_code_piece}}
+```
@@ -476,7 +488,11 @@ TMQ 消息队列是一个 [futures::Stream](https://docs.rs/futures/latest/futur
-同 Websocket 代码样例。
+```rust
+{{#include docs/examples/rust/restexample/examples/subscribe_demo.rs:consumer_commit_manually}}
+```
+
+可以通过 `consumer.commit` 方法来手工提交消费进度。
@@ -541,19 +557,15 @@ TMQ 消息队列是一个 [futures::Stream](https://docs.rs/futures/latest/futur
{{#include docs/examples/csharp/wssubscribe/Program.cs:close}}
```
-
-
-
-
-
### 原生连接
-同 Websocket 代码样例。
-
+```java
+{{#include examples/JDBC/JDBCDemo/src/main/java/com/taosdata/example/WsConsumerLoopFull.java:unsubscribe_data_code_piece}}
+```
@@ -570,7 +582,11 @@ TMQ 消息队列是一个 [futures::Stream](https://docs.rs/futures/latest/futur
-同 Websocket 代码样例。
+```rust
+{{#include docs/examples/rust/restexample/examples/tmq.rs:unsubscribe}}
+```
+
+**注意**：消费者取消订阅后无法重用，如果想订阅新的 `topic`， 请重新创建消费者。
@@ -638,10 +654,6 @@ TMQ 消息队列是一个 [futures::Stream](https://docs.rs/futures/latest/futur
```
-
-
-
-
### 原生连接