Merge pull request #18700 from taosdata/TD-20967
test:comment commit of tmq consumer in crashGen
This commit is contained in:
commit
d638019a93
|
@ -2026,7 +2026,7 @@ class TdSuperTable:
|
|||
", "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:
|
||||
|
|
Loading…
Reference in New Issue