fix(driver): initialize variable when only use tmq

This commit is contained in:
huolibo 2022-08-26 17:26:02 +08:00
parent fe4d13da3d
commit f8ab11e2fc
1 changed files with 1 additions and 0 deletions

View File

@ -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;
}