Skip to content

Commit f2da621

Browse files
authored
fix: Add flags for path & configure kafka for non-memberlist kv store (#14850)
1 parent b2f3d2e commit f2da621

File tree

3 files changed

+4
-0
lines changed

3 files changed

+4
-0
lines changed

‎docs/sources/shared/configuration.md‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1620,6 +1620,8 @@ The `chunk_store_config` block configures how chunks will be cached and how long
16201620
Common configuration to be shared between multiple modules. If a more specific configuration is given in other sections, the related configuration within this section will be ignored.
16211621

16221622
```yaml
1623+
# prefix for the path
1624+
# CLI flag: -common.path-prefix
16231625
[path_prefix: <string> | default = ""]
16241626
16251627
storage:

‎pkg/loki/common/common.go‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -66,6 +66,7 @@ func (c *Config) RegisterFlags(f *flag.FlagSet) {
6666

6767
f.StringVar(&c.CompactorAddress, "common.compactor-address", "", "the http address of the compactor in the form http://host:port")
6868
f.StringVar(&c.CompactorGRPCAddress, "common.compactor-grpc-address", "", "the grpc address of the compactor in the form host:port")
69+
f.StringVar(&c.PathPrefix, "common.path-prefix", "", "prefix for the path")
6970
}
7071

7172
type Storage struct {

‎pkg/loki/config_wrapper.go‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -244,6 +244,7 @@ func applyConfigToRings(r, defaults *ConfigWrapper, rc lokiring.RingConfig, merg
244244
r.Ingester.LifecyclerConfig.Zone = rc.InstanceZone
245245
r.Ingester.LifecyclerConfig.ListenPort = rc.ListenPort
246246
r.Ingester.LifecyclerConfig.ObservePeriod = rc.ObservePeriod
247+
r.Ingester.KafkaIngestion.PartitionRingConfig.KVStore = rc.KVStore
247248
}
248249

249250
if mergeWithExisting {

0 commit comments

Comments
 (0)