addIngestBlocks adds the ingest.kafka configuration for microservices mode.
(m map[string]interface{}, mode, kafkaAddress, kafkaTopic string)
| 200 | |
| 201 | // addIngestBlocks adds the ingest.kafka configuration for microservices mode. |
| 202 | func addIngestBlocks(m map[string]interface{}, mode, kafkaAddress, kafkaTopic string) error { |
| 203 | if mode == modeMonolithic { |
| 204 | return nil |
| 205 | } |
| 206 | |
| 207 | if kafkaAddress == "" { |
| 208 | return fmt.Errorf("--kafka-address is required in microservices mode") |
| 209 | } |
| 210 | |
| 211 | setNestedValue(m, []string{"ingest", "kafka", "address"}, kafkaAddress) |
| 212 | setNestedValue(m, []string{"ingest", "kafka", "topic"}, kafkaTopic) |
| 213 | return nil |
| 214 | } |
| 215 | |
| 216 | // modifyOverrides sets compaction_disabled: true in the overrides defaults and |
| 217 | // any inline per-tenant overrides, and warns about external per-tenant files. |