From 2f261ca53a80232ce487ea35d754259611ec2bbb Mon Sep 17 00:00:00 2001 From: Edward Welch Date: Wed, 3 Apr 2024 18:29:12 +0000 Subject: [PATCH] by default enable stream sharding Signed-off-by: Edward Welch --- pkg/distributor/shardstreams/config.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/pkg/distributor/shardstreams/config.go b/pkg/distributor/shardstreams/config.go index 90f1e65600a9b..1bf1f89f961c6 100644 --- a/pkg/distributor/shardstreams/config.go +++ b/pkg/distributor/shardstreams/config.go @@ -16,8 +16,8 @@ type Config struct { } func (cfg *Config) RegisterFlagsWithPrefix(prefix string, fs *flag.FlagSet) { - fs.BoolVar(&cfg.Enabled, prefix+".enabled", false, "Automatically shard streams to keep them under the per-stream rate limit") + fs.BoolVar(&cfg.Enabled, prefix+".enabled", true, "Automatically shard streams to keep them under the per-stream rate limit") fs.BoolVar(&cfg.LoggingEnabled, prefix+".logging-enabled", false, "Enable logging when sharding streams") - cfg.DesiredRate.Set("3mb") //nolint:errcheck - fs.Var(&cfg.DesiredRate, prefix+".desired-rate", "threshold used to cut a new shard. Default (3MB) means if a rate is above 3MB, it will be sharded.") + cfg.DesiredRate.Set("1536KB") //nolint:errcheck + fs.Var(&cfg.DesiredRate, prefix+".desired-rate", "threshold used to cut a new shard. Default (1536KB) means if a rate is above 1536KB/s, it will be sharded.") }