secondary preferred

Author: jgao54

flow/connectors/mongo/mongo.go

@@ -46,7 +46,7 @@ func NewMongoConnector(ctx context.Context, config *protos.MongoConfig) (*MongoC
 
 	client, err := mongo.Connect(options.Client().
 		SetAppName("PeerDB Mongo Connector").
-		SetReadPreference(readpref.Primary()).
+		SetReadPreference(readpref.SecondaryPreferred()).
 		SetCompressors([]string{"zstd", "snappy"}).
 		ApplyURI(config.Uri))
 	if err != nil {