[autothrottle] only init KafkaAdmin if needed

DataDog · Apr 25, 2022 · 0105db0 · 0105db0
1 parent 015351a
commit 0105db0
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/cmd/autothrottle/main.go b/cmd/autothrottle/main.go
@@ -193,8 +193,12 @@ func main() {
 		failureThreshold:       Config.FailureThreshold,
 	}
 
-	if err := ThrottleManager.InitKafkaAdmin(Config.BootstrapServers); err != nil {
-		log.Fatal(err)
+	// Init a KafkaAdmin Client if needed.
+	if Config.KafkaNativeMode {
+		if err := ThrottleManager.InitKafkaAdmin(Config.BootstrapServers); err != nil {
+			log.Fatal(err)
+		}
+		log.Printf("Connected to Kafka: %s\n", Config.BootstrapServers)
 	}
 
 	// Run.