Only add consume config for appropriate scrapeMode

redpanda-data · Nov 4, 2021 · fcd8c0c · fcd8c0c
1 parent c1e922e
commit fcd8c0c
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/minion/service.go b/minion/service.go
@@ -45,8 +45,11 @@ func NewService(cfg Config, logger *zap.Logger, kafkaSvc *kafka.Service, metrics
 	minionHooks := newMinionClientHooks(logger.Named("kafka_hooks"), metricsNamespace)
 	kgoOpts := []kgo.Opt{
 		kgo.WithHooks(minionHooks),
-		kgo.ConsumeTopics("__consumer_offsets"),
-		kgo.ConsumeResetOffset(kgo.NewOffset().AtStart()),
+	}
+	if cfg.ConsumerGroups.ScrapeMode == ConsumerGroupScrapeModeOffsetsTopic {
+		kgoOpts = append(kgoOpts,
+			kgo.ConsumeResetOffset(kgo.NewOffset().AtStart()),
+			kgo.ConsumeTopics("__consumer_offsets"))
 	}
 
 	client, err := kafkaSvc.CreateAndTestClient(ctx, logger, kgoOpts)