no empty key

chaos/common/message/MessagePSConsumer.cpp

@@ -69,6 +69,10 @@ ele_uptr_t MessagePSConsumer::getMsg(int timeo) {
 
 int MessagePSConsumer::subscribe(const std::string& key) {
   std::string topic = key;
+  if(key.size()==0){
+      MRDERR_ << " empty subscription name";
+      return -1;
+  }
   std::replace(topic.begin(), topic.end(), '/', '.');
   std::replace(topic.begin(), topic.end(), ':', '.');
 

chaos/common/message/impl/kafka/rdk/MessagePSRDKafkaConsumer.cpp

@@ -145,7 +145,10 @@ int MessagePSRDKafkaConsumer::applyConfiguration() {
 }
 
 int MessagePSRDKafkaConsumer::subscribe(const std::string& key) {
-  MessagePSConsumer::subscribe(key);
+  int ret=MessagePSConsumer::subscribe(key);
+  if(ret!=0){
+    return ret;
+  }
   if (rk == NULL) {
     errstr = "apply configuration first!";
     MRDERR_ << errstr;