From b06203e777e9dd1d2a1fe44feff0b4ead21f73ac Mon Sep 17 00:00:00 2001
From: winlin <winlin@vip.126.com>
Date: Thu, 8 Dec 2016 11:48:50 +0800
Subject: [PATCH] dispose kafka

---
 trunk/src/app/srs_app_kafka.cpp | 3 +++
 1 file changed, 3 insertions(+)

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()