enh: add tmq_get_connect

taosdata · Oct 30, 2023 · 94273f7 · 94273f7
1 parent 7298f07
commit 94273f7
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/wrapper/tmq.go b/wrapper/tmq.go
@@ -328,3 +328,8 @@ func TMQCommitOffsetAsync(consumer unsafe.Pointer, topic string, vGroupID int32,
 	defer C.free(unsafe.Pointer(topicName))
 	C.tmq_commit_offset_async((*C.tmq_t)(consumer), topicName, (C.int32_t)(vGroupID), (C.int64_t)(offset), (*C.tmq_commit_cb)(C.TMQCommitOffsetCB), h.Pointer())
 }
+
+// TMQGetConnect TAOS *tmq_get_connect(tmq_t *tmq)
+func TMQGetConnect(consumer unsafe.Pointer) unsafe.Pointer {
+	return unsafe.Pointer(C.tmq_get_connect((*C.tmq_t)(consumer)))
+}