diff --git a/internal/push/consumer_init.go b/internal/push/consumer_init.go
index 6e6a2e898..673c9f6f4 100644
--- a/internal/push/consumer_init.go
+++ b/internal/push/consumer_init.go
@@ -17,8 +17,6 @@ package push
 import (
 	"context"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/config"
-
-	"github.com/OpenIMSDK/tools/log"
 )
 
 type Consumer struct {
@@ -37,9 +35,5 @@ func NewConsumer(config *config.GlobalConfig, pusher *Pusher) (*Consumer, error)
 }
 
 func (c *Consumer) Start() {
-	onError := func(ctx context.Context, err error, errInfo string) {
-		log.ZWarn(ctx, errInfo, err)
-	}
-	go c.pushCh.pushConsumerGroup.RegisterHandleAndConsumer(context.Background(), &c.pushCh, onError)
-
+	go c.pushCh.pushConsumerGroup.RegisterHandleAndConsumer(context.Background(), &c.pushCh)
 }