for #515, use srs_freepa to free array.

@@ -55,7 +55,7 @@ SrsKafkaString::SrsKafkaString(string v)
 
 
 SrsKafkaString::~SrsKafkaString()
 SrsKafkaString::~SrsKafkaString()
 {
 {
-    srs_freep(data);
+    srs_freepa(data);
 }
 }
 
 
 bool SrsKafkaString::null()
 bool SrsKafkaString::null()
@@ -80,7 +80,7 @@ string SrsKafkaString::to_str()
 void SrsKafkaString::set_value(string v)
 void SrsKafkaString::set_value(string v)
 {
 {
     // free previous data.
     // free previous data.
-    srs_freep(data);
+    srs_freepa(data);
     
     
     // copy new value to data.
     // copy new value to data.
     _size = (int16_t)v.length();
     _size = (int16_t)v.length();
@@ -147,7 +147,7 @@ int SrsKafkaString::decode(SrsBuffer* buf)
         return ret;
         return ret;
     }
     }
     
     
-    srs_freep(data);
+    srs_freepa(data);
     data = new char[_size];
     data = new char[_size];
     
     
     buf->read_bytes(data, _size);
     buf->read_bytes(data, _size);
@@ -171,7 +171,7 @@ SrsKafkaBytes::SrsKafkaBytes(const char* v, int nb_v)
 
 
 SrsKafkaBytes::~SrsKafkaBytes()
 SrsKafkaBytes::~SrsKafkaBytes()
 {
 {
-    srs_freep(_data);
+    srs_freepa(_data);
 }
 }
 
 
 char* SrsKafkaBytes::data()
 char* SrsKafkaBytes::data()
@@ -202,7 +202,7 @@ void SrsKafkaBytes::set_value(string v)
 void SrsKafkaBytes::set_value(const char* v, int nb_v)
 void SrsKafkaBytes::set_value(const char* v, int nb_v)
 {
 {
     // free previous data.
     // free previous data.
-    srs_freep(_data);
+    srs_freepa(_data);
     
     
     // copy new value to data.
     // copy new value to data.
     _size = (int16_t)nb_v;
     _size = (int16_t)nb_v;
@@ -280,7 +280,7 @@ int SrsKafkaBytes::decode(SrsBuffer* buf)
         return ret;
         return ret;
     }
     }
     
     
-    srs_freep(_data);
+    srs_freepa(_data);
     _data = new char[_size];
     _data = new char[_size];
     buf->read_bytes(_data, _size);
     buf->read_bytes(_data, _size);