diff --git a/weed/mq/broker/broker_grpc_pub.go b/weed/mq/broker/broker_grpc_pub.go
index 3937399bd..ab4320a9d 100644
--- a/weed/mq/broker/broker_grpc_pub.go
+++ b/weed/mq/broker/broker_grpc_pub.go
@@ -67,7 +67,7 @@ func (b *MessageQueueBroker) PublishMessage(stream mq_pb.SeaweedMessaging_Publis
 	// connect to follower brokers
 	if localTopicPartition.FollowerStream == nil && len(initMessage.FollowerBrokers) > 0 {
 		follower := initMessage.FollowerBrokers[0]
-		ctx := stream.Context()
+		ctx := context.Background()
 		localTopicPartition.FollowerGrpcConnection, err = pb.GrpcDial(ctx, follower, true, b.grpcDialOption)
 		if err != nil {
 			response.Error = fmt.Sprintf("fail to dial %s: %v", follower, err)