fix: update filters config check

Lakshay Kalbhor · Lakshay Kalbhor · commit 7bf29b9b524e · 2024-05-06T16:12:02.000+05:30
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.")
 	}
 

Original file line number	Diff line number	Diff line change
`@@ -195,7 +195,7 @@ func initKafkaConfig(ko *koanf.Koanf) ([]relay.ConsumerGroupCfg, relay.ProducerC`
`195`	`195`
`196`	`196`	`// initFilters loads the go plugin, initializes it and return a map of filter plugins.`
`197`	`197`	`func initFilters(ko koanf.Koanf, lo slog.Logger) (map[string]filter.Provider, error) {`
`198`		`- if ko.String("mode") != "single" {`
	`198`	`+ if ko.String("mode") != "single" && len(ko.MapKeys("filters")) > 0 {`
`199`	`199`	log.Fatalf("filters can only be used in `single` mode.")
`200`	`200`	`}`
`201`	`201`