diff --git a/consume/egg_record_active_consume.go b/consume/egg_record_active_consume.go
index 2b16980..aed9c73 100644
--- a/consume/egg_record_active_consume.go
+++ b/consume/egg_record_active_consume.go
@@ -103,8 +103,9 @@ func handleEggRecordActiveDataConsume(msgData []byte) error {
 					return err1
 				}
 				return nil
+			} else {
+				return err
 			}
-			return err
 		}
 	}