diff --git a/consume/egg_canal_invite_user_nums_consume.go b/consume/egg_canal_invite_user_nums_consume.go
index bd44c53..6672786 100644
--- a/consume/egg_canal_invite_user_nums_consume.go
+++ b/consume/egg_canal_invite_user_nums_consume.go
@@ -73,6 +73,9 @@ func handleEggCanalInviteUserNumsConsume(msg []byte) error {
 	// 2. 监听插入信息
 	if canalMsg.Type == md2.CanalMsgInsertSqlType {
 		for _, item := range canalMsg.Data {
+			if item.Level != "1" {
+				return nil
+			}
 			parentUid := item.ParentUid
 			id := fmt.Sprintf("%d%d_%s", year, week, parentUid)