()
| 313 | } |
| 314 | |
| 315 | func (t *App) configureGenerator() { |
| 316 | t.cfg.Generator.Ingest = t.cfg.Ingest |
| 317 | t.cfg.Generator.ConsumeFromKafka = !IsSingleBinary(t.cfg.Target) |
| 318 | if t.cfg.Generator.ConsumeFromKafka && t.cfg.Generator.RingMode == generator.RingModePartition { |
| 319 | t.cfg.Generator.Ingest.Kafka.ConsumerGroup = generator.ConsumerGroup |
| 320 | } |
| 321 | } |
| 322 | |
| 323 | func (t *App) generatorRingReader() (ring.PartitionRingReader, error) { |
| 324 | if IsSingleBinary(t.cfg.Target) { |