xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Merge pull request #23138 from taosdata/docs/sunpeng/update-python-tmp-docs 

docs: update python tmq docs
This commit is contained in:
wade zhang 2023-10-08 10:01:50 +08:00 committed by GitHub
parent 95818f4acf 29737cf5b0
commit 3d72099a47
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 26 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
docs/en/07-develop/07-tmq.mdx
View File

@ -455,7 +455,19 @@ from taos.tmq import Consumer
# Syntax: `consumer = Consumer(configs)` # Syntax: `consumer = Consumer(configs)`
# #
# Example: # Example:
consumer = Consumer({"group.id": "local", "td.connect.ip": "127.0.0.1"}) consumer = Consumer(
{
"group.id": "local",
"client.id": "1",
"enable.auto.commit": "true",
"auto.commit.interval.ms": "1000",
"td.connect.ip": "127.0.0.1",
"td.connect.user": "root",
"td.connect.pass": "taosdata",
"auto.offset.reset": "earliest",
"msg.with.table.name": "true",
}
)
``` ```
</TabItem> </TabItem>

14
docs/zh/07-develop/07-tmq.md
View File

@ -456,7 +456,19 @@ from taos.tmq import Consumer
# Syntax: `consumer = Consumer(configs)` # Syntax: `consumer = Consumer(configs)`
# #
# Example: # Example:
consumer = Consumer({"group.id": "local", "td.connect.ip": "127.0.0.1"}) consumer = Consumer(
{
"group.id": "local",
"client.id": "1",
"enable.auto.commit": "true",
"auto.commit.interval.ms": "1000",
"td.connect.ip": "127.0.0.1",
"td.connect.user": "root",
"td.connect.pass": "taosdata",
"auto.offset.reset": "earliest",
"msg.with.table.name": "true",
}
)
``` ```
</TabItem> </TabItem>