diff --git a/chaos/common/message/impl/kafka/rdk/MessagePSRDKafkaConsumer.cpp b/chaos/common/message/impl/kafka/rdk/MessagePSRDKafkaConsumer.cpp
index ce53bba5e9756e87ce5db3184ea2991229a21ee9..3137ecd573f47b3472d3ff6c35fc7fcffabc0286 100644
--- a/chaos/common/message/impl/kafka/rdk/MessagePSRDKafkaConsumer.cpp
+++ b/chaos/common/message/impl/kafka/rdk/MessagePSRDKafkaConsumer.cpp
@@ -113,7 +113,7 @@ int MessagePSRDKafkaConsumer::applyConfiguration() {
     }*/
     if (rk == NULL) {
       MRDDBG_ << "Consumer apply configuration, groupid:" << groupid;
-      if (groupid != "") {
+      if (groupid.size()) {
         if (setOption("group.id", groupid.c_str()) != 0) {
           return -2;
         }
diff --git a/chaos/common/rpc/psm/PSMServer.cpp b/chaos/common/rpc/psm/PSMServer.cpp
index 09ac8323f1c46cc534a2980c761010fac211ca5a..c37b59e981e368af5cd42b7090c0703aee967285 100644
--- a/chaos/common/rpc/psm/PSMServer.cpp
+++ b/chaos/common/rpc/psm/PSMServer.cpp
@@ -70,7 +70,10 @@ void PSMServer::init(void *init_data) {
         gname=cfg->getStringValue(InitOption::OPT_GROUP_NAME);
         PSMS_LAPP << "belong to group:\""<<gname<<"\"";
 
+    } else {
+        gname=nodeuid;
     }
+
     cons = chaos::common::message::MessagePSDriver::getNewConsumerDriver(msgbrokerdrv, gname);
     prod = chaos::common::message::MessagePSDriver::getProducerDriver(msgbrokerdrv);