From f7c5a82fc8f19465b5b64f1330f5c49e102fde7e Mon Sep 17 00:00:00 2001 From: wenzhouwww Date: Fri, 25 Nov 2022 10:59:40 +0800 Subject: [PATCH] Update crash_gen_main.py --- tests/pytest/crash_gen/crash_gen_main.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/tests/pytest/crash_gen/crash_gen_main.py b/tests/pytest/crash_gen/crash_gen_main.py index fb0bc5ebea..4140728dcd 100755 --- a/tests/pytest/crash_gen/crash_gen_main.py +++ b/tests/pytest/crash_gen/crash_gen_main.py @@ -2022,10 +2022,11 @@ class TdSuperTable: conf.set("group.id", "tg2") conf.set("td.connect.user", "root") conf.set("td.connect.pass", "taosdata") - conf.set("enable.auto.commit", "true") + conf.set("enable.auto. + ", "true") def tmq_commit_cb_print(tmq, resp, offset, param=None): print(f"commit: {resp}, tmq: {tmq}, offset: {offset}, param: {param}") - #conf.set_auto_commit_cb(tmq_commit_cb_print, None) + conf.set_auto_commit_cb(tmq_commit_cb_print, None) consumer = conf.new_consumer() topic_list = TaosTmqList() for topic in current_topic_list: -- GitLab