docs: add version requirements

This commit is contained in:
Adam Ji 2023-06-05 15:12:58 +08:00
parent c29e5b72d9
commit cc8a1b17be
1 changed files with 5 additions and 0 deletions

View File

@ -504,12 +504,17 @@ TMQ 消息队列是一个 [futures::Stream](https://docs.rs/futures/latest/futur
获取消费进度:
版本要求 connector-rust >= v0.8.8 TDengine >= 3.0.5.0
```rust
let assignments = consumer.assignments().await.unwrap();
```
按照指定的进度消费:
版本要求 connector-rust >= v0.8.8 TDengine >= 3.0.5.0
```rust
consumer.offset_seek(topic, vgroup_id, offset).await;
```