docs: add version
This commit is contained in:
parent
b1800a2bd5
commit
985362d94c
|
@ -501,12 +501,16 @@ The TMQ is of [futures::Stream](https://docs.rs/futures/latest/futures/stream/in
|
||||||
|
|
||||||
Get assignments:
|
Get assignments:
|
||||||
|
|
||||||
|
Version requirements connector-rust >= v0.8.8, TDengine >= 3.0.5.0
|
||||||
|
|
||||||
```rust
|
```rust
|
||||||
let assignments = consumer.assignments().await.unwrap();
|
let assignments = consumer.assignments().await.unwrap();
|
||||||
```
|
```
|
||||||
|
|
||||||
Seek offset:
|
Seek offset:
|
||||||
|
|
||||||
|
Version requirements connector-rust >= v0.8.8, TDengine >= 3.0.5.0
|
||||||
|
|
||||||
```rust
|
```rust
|
||||||
consumer.offset_seek(topic, vgroup_id, offset).await;
|
consumer.offset_seek(topic, vgroup_id, offset).await;
|
||||||
```
|
```
|
||||||
|
|
Loading…
Reference in New Issue