From f8ab11e2fc67de53545a581a355dc3233f28f261 Mon Sep 17 00:00:00 2001
From: huolibo <huolibo@qq.com>
Date: Fri, 26 Aug 2022 17:26:02 +0800
Subject: [PATCH] fix(driver): initialize variable when only use tmq

---
 source/client/src/TMQConnector.c | 1 +
 1 file changed, 1 insertion(+)

diff --git a/source/client/src/TMQConnector.c b/source/client/src/TMQConnector.c
index 17d3a212c4..fcf6957df9 100644
--- a/source/client/src/TMQConnector.c
+++ b/source/client/src/TMQConnector.c
@@ -42,6 +42,7 @@ void commit_cb(tmq_t *tmq, int32_t code, void *param) {
 
 JNIEXPORT jlong JNICALL Java_com_taosdata_jdbc_tmq_TMQConnector_tmqConfNewImp(JNIEnv *env, jobject jobj) {
   tmq_conf_t *conf = tmq_conf_new();
+  jniGetGlobalMethod(env);
   return (jlong)conf;
 }