fix: update filters config check

zerodha · May 6, 2024 · 7bf29b9 · 7bf29b9
1 parent 5ccccee
commit 7bf29b9
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/init.go b/init.go
@@ -195,7 +195,7 @@ func initKafkaConfig(ko *koanf.Koanf) ([]relay.ConsumerGroupCfg, relay.ProducerC
 
 // initFilters loads the go plugin, initializes it and return a map of filter plugins.
 func initFilters(ko *koanf.Koanf, lo *slog.Logger) (map[string]filter.Provider, error) {
-	if ko.String("mode") != "single" {
+	if ko.String("mode") != "single" && len(ko.MapKeys("filters")) > 0 {
 		log.Fatalf("filters can only be used in `single` mode.")
 	}