diff --git a/chaos/common/message/impl/kafka/rdk/MessagePSRDKafka.cpp b/chaos/common/message/impl/kafka/rdk/MessagePSRDKafka.cpp index 4bb5017458d717f33425759362f8b26d1d5be22c..53357fabc75f5df02856033e71c65d426cbd6210 100644 --- a/chaos/common/message/impl/kafka/rdk/MessagePSRDKafka.cpp +++ b/chaos/common/message/impl/kafka/rdk/MessagePSRDKafka.cpp @@ -14,14 +14,14 @@ MessagePSRDKafka::~MessagePSRDKafka() { boost::mutex::scoped_lock ll(io); MRDDBG_<<" DESTROY KAFKA"; - if(conf){ + /*if(conf){ rd_kafka_conf_destroy(conf); conf=NULL; } if(topic_conf){ rd_kafka_topic_conf_destroy(topic_conf); topic_conf=NULL; - } + }*/ }