kafka rename message set to raw message set.

@@ -461,11 +461,11 @@ SrsKafkaRawMessage::~SrsKafkaRawMessage()
     srs_freep(value);
     srs_freep(value);
 }
 }
 
 
-SrsKafkaMessageSet::SrsKafkaMessageSet()
+SrsKafkaRawMessageSet::SrsKafkaRawMessageSet()
 {
 {
 }
 }
 
 
-SrsKafkaMessageSet::~SrsKafkaMessageSet()
+SrsKafkaRawMessageSet::~SrsKafkaRawMessageSet()
 {
 {
     vector<SrsKafkaRawMessage*>::iterator it;
     vector<SrsKafkaRawMessage*>::iterator it;
     for (it = messages.begin(); it != messages.end(); ++it) {
     for (it = messages.begin(); it != messages.end(); ++it) {

@@ -413,13 +413,13 @@ public:
  * a set of kafka message.
  * a set of kafka message.
  * @see https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-Messagesets
  * @see https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-Messagesets
  */
  */
-class SrsKafkaMessageSet
+class SrsKafkaRawMessageSet
 {
 {
 private:
 private:
     std::vector<SrsKafkaRawMessage*> messages;
     std::vector<SrsKafkaRawMessage*> messages;
 public:
 public:
-    SrsKafkaMessageSet();
-    virtual ~SrsKafkaMessageSet();
+    SrsKafkaRawMessageSet();
+    virtual ~SrsKafkaRawMessageSet();
 };
 };
 
 
 /**
 /**