diff --git a/trunk/src/protocol/srs_kafka_stack.cpp b/trunk/src/protocol/srs_kafka_stack.cpp
index 622507d51..e935b8c3f 100644
--- a/trunk/src/protocol/srs_kafka_stack.cpp
+++ b/trunk/src/protocol/srs_kafka_stack.cpp
@@ -461,11 +461,11 @@ SrsKafkaRawMessage::~SrsKafkaRawMessage()
     srs_freep(value);
 }
 
-SrsKafkaMessageSet::SrsKafkaMessageSet()
+SrsKafkaRawMessageSet::SrsKafkaRawMessageSet()
 {
 }
 
-SrsKafkaMessageSet::~SrsKafkaMessageSet()
+SrsKafkaRawMessageSet::~SrsKafkaRawMessageSet()
 {
     vector<SrsKafkaRawMessage*>::iterator it;
     for (it = messages.begin(); it != messages.end(); ++it) {
diff --git a/trunk/src/protocol/srs_kafka_stack.hpp b/trunk/src/protocol/srs_kafka_stack.hpp
index 520c9bdea..1ea3ae8c1 100644
--- a/trunk/src/protocol/srs_kafka_stack.hpp
+++ b/trunk/src/protocol/srs_kafka_stack.hpp
@@ -413,13 +413,13 @@ public:
  * a set of kafka message.
  * @see https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-Messagesets
  */
-class SrsKafkaMessageSet
+class SrsKafkaRawMessageSet
 {
 private:
     std::vector<SrsKafkaRawMessage*> messages;
 public:
-    SrsKafkaMessageSet();
-    virtual ~SrsKafkaMessageSet();
+    SrsKafkaRawMessageSet();
+    virtual ~SrsKafkaRawMessageSet();
 };
 
 /**