diff --git a/source/dnode/mnode/impl/src/mndSubscribe.c b/source/dnode/mnode/impl/src/mndSubscribe.c
index ad36d48a1f..da36dc30e4 100644
--- a/source/dnode/mnode/impl/src/mndSubscribe.c
+++ b/source/dnode/mnode/impl/src/mndSubscribe.c
@@ -657,7 +657,7 @@ END:
 }
 
 static int32_t presistConsumerByType(STrans *pTrans, SArray *consumers, int8_t type, char *cgroup, char *topic) {
-  if (pTrans == NULL || consumers == NULL || cgroup == NULL || topic == NULL) {
+  if (pTrans == NULL || consumers == NULL || cgroup == NULL) {
     return TSDB_CODE_INVALID_PARA;
   }
   int32_t         code = 0;