diff --git a/trunk/src/app/srs_app_kafka.cpp b/trunk/src/app/srs_app_kafka.cpp
index fc76613c0..32ad3b629 100644
--- a/trunk/src/app/srs_app_kafka.cpp
+++ b/trunk/src/app/srs_app_kafka.cpp
@@ -348,6 +348,9 @@ void srs_dispose_kafka()
 {
     SrsKafkaProducer* kafka = dynamic_cast<SrsKafkaProducer*>(_srs_kafka);
     kafka->stop();
+    
+    srs_freep(kafka);
+    _srs_kafka = NULL;
 }
 
 SrsKafkaProducer::SrsKafkaProducer()