fix(injector): ads error checking to pass the golangci errorchecking

Author: João Assunção

cmd/injector.go

@@ -33,10 +33,7 @@ func main() {
 	metrics.Register()
 	schemaRegistry, err := schema_registry.NewSchemaRegistry(os.Getenv("SCHEMA_REGISTRY_URL"))
 	if err != nil {
-		err = level.Error(logger).Log("err", err, "message", "failed to create schema registry client")
-		if err != nil {
-			panic(err)
-		}
+		level.Error(logger).Log("err", err, "message", "failed to create schema registry client")
 	}
 
 	kafkaConfig := &kafka.Config{

src/injector/injector.go

@@ -39,7 +39,10 @@ func MakeKafkaConsumer(endpoints Endpoints, logger log.Logger, schemaRegistry *s
 
 	includeKey, err := strconv.ParseBool(kafkaConfig.IncludeKey)
 	if err != nil {
-		level.Warn(logger).Log("err", err, "message", "failed to get consumer with key and value")
+		err = level.Warn(logger).Log("err", err, "message", "failed to get consumer include key configuration flag")
+		if err != nil {
+			panic(err)
+		}
 		includeKey = false
 	}