From 28782d2cd8123d87ec7813bbc67caf28486359c4 Mon Sep 17 00:00:00 2001 From: liuxueli Date: Fri, 25 Feb 2022 18:08:50 +0800 Subject: [PATCH] =?UTF-8?q?TSG-9700:=20TSG=5FMASTER=5FUNLOAD=E4=BD=BF?= =?UTF-8?q?=E7=94=A8=E9=94=99=E8=AF=AF=E7=9A=84=E5=88=A4=E6=96=AD=E6=9D=A1?= =?UTF-8?q?=E4=BB=B6=E5=AF=BC=E8=87=B4=E6=9C=AA=E9=94=80=E6=AF=81kakfa?= =?UTF-8?q?=E5=8F=A5=E6=9F=84=EF=BC=8C=E9=80=80=E5=87=BA=E9=87=8A=E6=94=BE?= =?UTF-8?q?=E8=B5=84=E6=BA=90=E6=97=B6=E5=BC=95=E8=B5=B7=E6=AE=B5=E9=94=99?= =?UTF-8?q?=E8=AF=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/tsg_send_log.cpp | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/tsg_send_log.cpp b/src/tsg_send_log.cpp index 91993ec..314c1ee 100644 --- a/src/tsg_send_log.cpp +++ b/src/tsg_send_log.cpp @@ -1655,7 +1655,7 @@ void tsg_sendlog_destroy(struct tsg_log_instance_t * instance) return ; } - if(instance->mode==CLOSE) + if(instance->mode!=CLOSE) { for(int i=0; imax_service; i++) { @@ -1667,8 +1667,8 @@ void tsg_sendlog_destroy(struct tsg_log_instance_t * instance) rd_kafka_topic_destroy(instance->topic_rkt[i]); } - //rd_kafka_destroy_flags(instance->kafka_handle, 4); - //rd_kafka_destroy(instance->kafka_handle); + rd_kafka_destroy_flags(instance->kafka_handle, 4); + rd_kafka_destroy(instance->kafka_handle); free(instance->topic_rkt); instance->topic_rkt=NULL;